Добрый день. На нашем участке имеется теплица. Её главная проблема — перегрев в жаркое время, т.к. рассчитана в первую очередь на сибирскую весну. Единственный выход — постоянно открывать/закрывать двери и окна, чтобы поддерживать температуру. Но это не всегда возможно. А если это не сделать, то температура поднимается до +50 градусов, что явно не хорошо. А вечером всё можно заморозить. Так и началась её автоматизация.
В первую очередь мы купили Raspberry Pi 2. Разобравшись с ним, подключили датчик DS18B20 по этой статье. Затем были куплены два б/у автомобильных стеклоподъёмника. Как и все DC двигатели, они движутся в зависимости от полярности. Поэтому к каждому двигателю подключаем два реле: одно для открытия, другое для закрытия. Эти реле уже через транзисторы подключаем к самим портам GPIO. И питаем это всё дело аккумулятором 12V. Так же, чтобы не сжечь двигатели, в крайних положениях окна были установлены концевые выключатели, и в случае, если окно открылось/закрылось полностью рвут сеть.
А для связи мы используем WiFi адаптер TP-LINK с усовершенствованной антенной «Двойной квадрат» для уверенного приёма соседского WIFI домашнего WIFI роутера, который находиться на расстояние 40 метров.
Теперь пишем программу для управления этими приводами. Был выбран язык Python, т. к. у него нормальная поддержка Raspberry Pi и конкретно GPIO портов. Для того, чтобы открыть окно, нам нужно подать +3.3V на транзистор, который активирует реле, и то начнёт открывать окно. Чтобы его закрыть, делаем то же самое, только в это случаем наше реле подключено наоборот к приводу. Но на Raspberry мы просто подаём ток то на один порт, то на другой. Мы решили, что если температура больше 26 открываем окно в течение 1 секунды. Затем ждём 3 минуты. Если опять жарко, то открываем второе окно в течение секунды. Ждём опять 3 минуты, и делаем заново. То же самое с закрытием, только тут температура должна быть ниже 24 градусов. А вот и код:
import RPi.GPIO as GPIO import time import os import datetime GPIO.setmode(GPIO.BOARD) GPIO.cleanup() GPIO.setup(31, GPIO.OUT) GPIO.setup(33, GPIO.OUT) GPIO.setup(35, GPIO.OUT) GPIO.setup(37, GPIO.OUT) #Получаем температуру def gettemp(): if os.path.isdir("id датчика"): #Если датчик подключён, то считываем значение tfile2=open("/sys/bus/w1/devices/id датчика") ttext2=tfile2.read() tfile2.close() temp2=ttext2.split("\n")[1].split(" ")[9] t2=float(temp2[2:])/1000 print t2 else: #если нет, то задаём дефолтное print ('File not found') t2==24 return t2 t2=24 #Задаём дефолтное значение для датчика while True: вечный цикл t2=gettemp() if t2<24: #Если температура меньше 24, то закрываем окно в течение секунды GPIO.output(37, 1) print ("close1") time.sleep(1) GPIO.output(37, 0) elif t2>26: #Если больше 26, то открываем окно в течение секунды GPIO.output(35, 1) print ("open1") time.sleep(2) GPIO.output(35, 0) else: #Иначе ничего не делаем print ("none1") time.sleep(180)#Ждём 3 минуты #Опять читаем температуру t2=gettemp() #Всё то же самое, только со вторым окном. if t2<24: GPIO.output(33, 1) print ("close2") time.sleep(1) GPIO.output(33, 0) elif t2>26: GPIO.output(31, 1) print ("open2") time.sleep(1) GPIO.output(31, 0) else: print ("none2") #Опять ждём 3 минуты time.sleep(180) А теперь начинается шоу для тех, кому физика не интересна.
Установив Apache на дистрибутив Raspbian, мы в течение месяца не могли достучаться до странички из интернета. Что только не делали. Настраивали порты, открывали их, ничего не помогала. Причём в локальной сети всё работали. Потом мы узнали печальную правду: мы находимся за NAT. И услуг по выделенному IP наш оператор для предоставляет (Привет сотрудникам Регион Телекома). Перебирали много обходных методов, но ничего не выходило. Пытался сделать веб интерфейс на хостинге, но для синхронизации базы данных тоже нужен IP. Брокер IPv6 к тому времени уже закрылся. А делать VPN дорого, ведь хочется всё бесплатно. И тут решили использовать Telegram бота. Как оказалось он имеет два режима: постоянный опрос сервера и отправка сообщений прямо к нам. Первый вариант подходил, т.к. не требует от нам IP адреса. Покопавшись в интернете нашёл библиотеку: pytelegrambotapi. И принялся за написание кода. Правда выходили и проблемы. Еле найденная MySQL библиотека отказывалась писать в базу данных, но при это читала из неё всё нормально. Пришлось делать костыль: передавать данные в файл, хранящийся в ОЗУ, затем запускать bash скрипт, который считает данные и занесёт в БД.
Делаем файл config.ini, туда кидаем:
[mysql] host = localhost database = telegram user = root password = secret</code> Не забываем данные заменить на свои. Создаём файл python_mysql_dbconfig.py , со следующим содержимым: <source lang="python">from configparser import ConfigParser def read_db_config(filename='config.ini', section='mysql'): """ Read database configuration file and return a dictionary object :param filename: name of the configuration file :param section: section of database configuration :return: a dictionary of database parameters """ # create parser and read ini configuration file parser = ConfigParser() parser.read(filename) # get section, default to mysql db = {} if parser.has_section(section): items = parser.items(section) for item in items: db[item[0]] = item[1] else: raise Exception('{0} not found in the {1} file'.format(section, filename)) return dbТак же нам нужно создать файл python_mysql_connect2.py, с вот таким содержимым:
from mysql.connector import MySQLConnection, Error from python_mysql_dbconfig import read_db_config def connect(): """ Connect to MySQL database """ db_config = read_db_config() try: print('Connecting to MySQL database...') conn = MySQLConnection(**db_config) if conn.is_connected(): print('connection established.') else: print('connection failed.') except Error as error: print(error) finally: conn.close() print('Connection closed.') if __name__ == '__main__': connect() Теперь мы всё подготовили для работы с БД.
Отвлечёмся немного от базы данных и перейдём непосредственно к общению с ботом. Ну как обычно, пишем @BotFather, и берём у него токен. Создаём файл config.py, и пишем в него две строчки:
# -*- coding: utf-8 -*- token = 'Ваш токен' Я решил реализовать в боте три функции:
- Получение температуры
- Получение снимков
- Управление окнами
С первым всё просто, по запросу читаем файл с температурой, и отправляем это пользователю.
Со снимками посложнее. Я использую утилиту Motion. В её параметрах проси класть в папку в оперативной памяти снимки, ну допустим каждые 30 секунд. И делаем файлы с одинаковыми имена, и они просто заменяют друг друга. А потом по запросу отправляем файл пользователю.
Ну и третий, самый сложный модуль: управление окнами. У меня главная задача: чтобы работала автоматика, но если нужно, то мы её можем отключить. Делал я это так. Создал в оперативной памяти очередной файл. Когда мы отправляем запрос на открытие/закрытие, приоткрытие, призакрытие окна или на включение/выключение автоматики бот пишет в этот файл номер команды. Каждые пять секунд программа управления окнами считывает этот файл, и если распознаёт команду, выполняет её. После выполнение в этот же файл пишет, что всё прошло успешно. Бот опять читает файл, и уведомляет нас, что команда выполнена.
Ну а теперь исходный код. Сначала та же самая программа для открывания окон, только уже переделанная под бота(temp.py):
import RPi.GPIO as GPIO import time import os import datetime GPIO.setmode(GPIO.BOARD) GPIO.cleanup() GPIO.setup(31, GPIO.OUT) GPIO.setup(33, GPIO.OUT) GPIO.setup(35, GPIO.OUT) GPIO.setup(37, GPIO.OUT) #Пишем в файл, что готовы к работе f = open('/mnt/raw/wind', 'w') f.write('OK') f.close() #Пишем, что автоматика включена f = open('/mnt/raw/pos', 'w') f.write('1') f.close() #получаем температуру def gettemp(): if os.path.isdir("/sys/bus/w1/devices/id датчика"): #Если датчик подключён, то считываем значение tfile2=open("/sys/bus/w1/devices/id датчика/w1_slave") ttext2=tfile2.read() tfile2.close() temp2=ttext2.split("\n")[1].split(" ")[9] t2=float(temp2[2:])/1000 print t2 else: #если нет, то задаём дефолтное print ('File not found') t2==24 return t2 #Включаем автоматику по дефолту i=1 #Дефолтная температура t2=24 #Читаем команды от бота def info(): f = open('/mnt/raw/wind') com = f.read() f.close() return com #Отвечаем боту, что всё успешно def ans(): f = open('/mnt/raw/wind', 'w') f.write('OK') f.close() print ("OK") #Анализируем команды def rob(): c = info() if c=="10": GPIO.output(37, 1) print ("close1") time.sleep(3) GPIO.output(37, 0) ans() elif c=="11": GPIO.output(35, 1) print ("open1") time.sleep(2) GPIO.output(35, 0) ans() elif c=="12": GPIO.output(37, 1) print ("close1") time.sleep(3) GPIO.output(37, 0) ans() elif c=="13": GPIO.output(35, 1) print ("open1") time.sleep(1) GPIO.output(35, 0) ans() elif c=="20": GPIO.output(33, 1) print ("close2") time.sleep(3) GPIO.output(33, 0) ans() elif c=="21": GPIO.output(31, 1) print ("open2") time.sleep(3) GPIO.output(31, 0) ans() elif c=="22": GPIO.output(33, 1) print ("close2") time.sleep(1) GPIO.output(33, 0) ans() elif c=="23": GPIO.output(31, 1) print ("open2") time.sleep(1) GPIO.output(31, 0) ans() elif c=="30": global i i=0 ans() f = open('/mnt/raw/pos', 'w') f.write('0') f.close() print('30') global i i=0 ans() elif c=="31": f = open('/mnt/raw/pos', 'w') f.write('1') f.close() print('31') global i i=1 ans() while True: #Читаем и выполняем команды rob() #Проверяем, включена ли автоматика if i==1: gettemp() if t2<24: GPIO.output(37, 1) print ("close1") time.sleep(1) GPIO.output(37, 0) elif t2>26: GPIO.output(35, 1) print ("open1") time.sleep(2) GPIO.output(35, 0) else: print ("none1") #Ожидаем 3 минуты, и в течение этого времени читаем команды j=0 while(j<36): rob() time.sleep(5) j=j+1 if i==0: break gettemp() if t2<24: GPIO.output(33, 1) print ("close2") time.sleep(1) GPIO.output(33, 0) elif t2>26: GPIO.output(31, 1) print ("open2") time.sleep(1) GPIO.output(31, 0) else: print ("none2") j=0 while(j<36): rob() time.sleep(5) j=j+1 if i==0: break Но а теперь поговорим про самого бота. Как я уже говорил, я использую библиотеку PyTelegramBotApi. Если обратиться к документации на GitHub, то можно понять что для обработки команд бот использует хендлеры. Хендлер — это событие в нашей программе, определяющие действие. В нашей случае это определенная фраза в сообщение. А действие это всё что мы можем сделать в языке python. В данном случае мы будет присылать пользователю какую-нибудь информацию пользователю или записывать команды для окон в файл. В основном наша программа состоит из этих самых хендлров и команды опроса сервера.
Но так же я сам написал и добавил ещё одно интересную вещь: блок авторизации. Ну как понятно из названия, он сделан для защиты нашей теплицы от несанкционированного доступа. Он работает просто. При первом подключение к боту он запрашивает у нас пароль. Если мы его вводим правильно, бот добавляет нас в базу данных, и при следующих подключениях нам уже авторизироваться не нужно. Бот узнаёт нас при помощи chat-id. Chat-id последнего пользователя храним в переменно, чтобы всё время не дёргать базу.
Теперь создаём файл daba.py и пишем туда вот это:
from mysql.connector import MySQLConnection, Error from python_mysql_dbconfig import read_db_config import time def getkey(): #Читаем пароль для бота try: dbconfig = read_db_config() conn = MySQLConnection(**dbconfig) cursor = conn.cursor() cursor.execute("SELECT key2 FROM tkey where id=0") row = cursor.fetchone() return row print(row) except Error as e: print(e) finally: cursor.close() conn.close() def sendup(): #Отправляем время запуска бота (не работает) stime=time.time() query = "INSERT INTO uptime(datetime, also) " \ "VALUES(now(), 20)" args=(stime) try: dbconfig = read_db_config() conn = MySQLConnection(**dbconfig) cursor = conn.cursor() cursor.execute(query) row = cursor.fetchone() return(row) print(row) except Error as e: print(e) finally: cursor.close() conn.close() def getid(idi): #проверяем есть ли id пользователя в базе query="SELECT accecpt FROM users WHERE chatid ='"+str(idi)+"'" try: dbconfig = read_db_config() conn = MySQLConnection(**dbconfig) cursor = conn.cursor() cursor.execute(query) row = cursor.fetchone() #print (str(row)) if str(row)=="None": return 0; print (0) else: return 20; except Error as e: print(e) #finally: #cursor.close() #conn.close() def newuser(idi): #Добавляем пользователя в базу данных query = ("INSERT INTO users SET `chatid`='12345'") try: dbconfig = read_db_config() conn = MySQLConnection(**dbconfig) cursor = conn.cursor() cursor.execute(query) row = cursor.fetchone() print(row) except Error as e: print(e) return(e) finally: cursor.close() conn.close() if __name__ == '__main__': query_with_fetchone() Так же давайте сразу сделаем ещё несколько вспомогательных скриптов. Создаём файл newuser.sh и пишем в него:
#!/bin/bash a=`cat /mnt/raw/user` cat /dev/null > /mnt/raw/user mysql -u root -pkoshak << EOF use telegram; INSERT INTO users(chatid) VALUES('$a'); EOF И создадим два скрипта для запуска бота и программы окон:
#!/bin/bash i=0 while [ $i = 0 ] do echo New python sleep 5 python3 bot.py done И ещё один:
#!/bin/bash i=0 while [ $i = 0 ] do echo New python sleep 5 python3 temp.py done «Зачем мы это делаем?» спросите вы. А тут дело в том, что иногда из-за нестабильного интернет соединения, или ошибки на сервера Telegram программа может вылететь. А скрипт её гоняет в вечном цикле: вылетела — запустил через 5 секунд снова. А для окон я сделал это на всякий пожарный: вдруг тоже из-за сбоя программа вылетит, а нас в теплице нет, вернёмся и будет у нас томатный суп или помидорное мороженное.
Ну и теперь самое главное, скрипт самого бота (bot.py):
# -*- coding: utf-8 -*- import config import telebot import subprocess import time from telebot import types import datetime import os from daba import getkey from daba import sendup from daba import getid #from daba import newuser #from temp import tep import os #Создаём файл f = open('/mnt/raw/user', 'tw', encoding='utf-8') f.close() global par par=0 #Текст для неавторизированного пользователя global a a="Вы не авторизированны. Пройдите авторизацию командой /auth [пароль]" #Функция получение температуры def get_temp(): if os.path.isdir("/sys/bus/w1/devices/id датчика"): tfile2=open("/sys/bus/w1/devices/id датчика/w1_slave") ttext2=tfile2.read() tfile2.close() temp2=ttext2.split("\n")[1].split(" ")[9] t2=float(temp2[2:])/1000 return t2 else: print ('File not found') #Пароль keyword=str(getkey())[2:-3] #Конфигурация токена bot = telebot.TeleBot(config.token) print (sendup()) #Создание кастомной клавиатуры #########################Клавиатура авторизации########################################## markup2 = types.ReplyKeyboardMarkup(row_width=1, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду markdown = types.ReplyKeyboardHide() #Деактивация itembtn5 = types.KeyboardButton(' Авторизация') #Название кнопки 5 markup2.add(itembtn5) #Занесение кнопок в матрицу #########################Клавиатура авторизации########################################## #########################Клавиатура главного меню########################################## markup = types.ReplyKeyboardMarkup(row_width=3, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn1 = types.KeyboardButton(' Прислать снимок') #Название кнопки 1 itembtn4 = types.KeyboardButton(' Управление окнами') itembtn2 = types.KeyboardButton(' Прислать температуру') #Название кнопки 2 markup.add(itembtn1, itembtn4, itembtn2) #Занесение кнопок в матрицу #########################Клавиатура главного меню########################################## #########################Ещё кнопки########################################## markup3 = types.ReplyKeyboardMarkup(row_width=2, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn10 = types.KeyboardButton(' Выключить автоматику ') #Название кнопки 10 itembtn11 = types.KeyboardButton('️ Ручное управление') itembtn12 = types.KeyboardButton(' Назад') markup3.add(itembtn10, itembtn11, itembtn12) #Занесение кнопок в матрицу markup4 = types.ReplyKeyboardMarkup(row_width=2, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn13 = types.KeyboardButton(' Включить автоматику ') #Название кнопки 13 markup4.add(itembtn13, itembtn11, itembtn12) #Занесение кнопок в матрицу markup5 = types.ReplyKeyboardMarkup(row_width=2, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn14 = types.KeyboardButton(' Первое окно') #Название кнопки 14 itembtn15 = types.KeyboardButton(' Второе окно') #Название кнопки 15 itembtn16 = types.KeyboardButton('️ Назад') #Название кнопки 16 markup5.add(itembtn14, itembtn15, itembtn16) #Занесение кнопок в матрицу markup6 = types.ReplyKeyboardMarkup(row_width=2, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn17 = types.KeyboardButton('️ Открыть окно ') #Название кнопки 17 itembtn18 = types.KeyboardButton('️ Закрыть окно ') #Название кнопки 18 itembtn19 = types.KeyboardButton(' Приоткрыть окно ') #Название кнопки 19 itembtn20 = types.KeyboardButton(' Призакрыть окно ') #Название кнопки20 itembtn21 = types.KeyboardButton('️ Назад') #Название кнопки 21 markup6.add(itembtn17, itembtn18, itembtn19, itembtn20, itembtn21) #Занесение кнопок в матрицу markup7 = types.ReplyKeyboardMarkup(row_width=2, resize_keyboard=True) #Активация, название, колва кнопок в одной ряду itembtn22 = types.KeyboardButton('️ Открыть окно ') #Название кнопки 22 itembtn23 = types.KeyboardButton('️ Закрыть окно ') #Название кнопки 23 itembtn24 = types.KeyboardButton(' Приоткрыть окно ') #Название кнопки24 itembtn25 = types.KeyboardButton(' Призакрыть окно ') #Название кнопки25 markup7.add(itembtn22, itembtn23, itembtn24, itembtn25, itembtn21) #Занесение кнопок в матрицу #########################Ещё кнопки########################################## bot.send_message(45215125, "Перезагрузка")#Вставьте сюда ваш chat-id #Узнаем состояние автоматики окон def pos(): f = open('/mnt/raw/pos') com = f.read() f.close() return com #Авторизация def avtor(idi): global par#Если пользователь храниться в переменной возвращаем ноль if par==idi: return 0 else:#Запрашиваем наличие пользователя в БД, если он там есть, возвращаем 0 if getid(str(idi))==20: par=idi#Заносим пользователя в переменную return 0 else:#Пишем что мы не знаем пользователя bot.send_message(idi, "Вы не авторизированны. Пройдите авторизацию командой /auth [пароль]", reply_markup=markup2) return 1 @bot.message_handler(regexp=" Авторизация") def auth(message): bot.send_message(message.chat.id, "Введите /auth [пароль]") #Тоже аворизация @bot.message_handler(commands=['auth']) def start2(message): if message.text[6:]==keyword:#Вырезаем пароль из сообщения if getid(str(message.chat.id))==20:#Проверяем пароль в базе данных, если пользователь там уже есть нам вернётся код 20 bot.send_message(message.chat.id, "Вы уже авторизированы") else: global par bot.send_message(message.chat.id, "Успешно", reply_markup=markup) par=message.chat.id #Отправляем chat-id в базу данных f = open('/mnt/raw/user', 'w') f.write(str(message.chat.id)) f.close() os.system('newuser.sh') print (message.chat.id) print (par) else: bot.send_message(message.chat.id, "Неверно") print (keyword) print (message.text[6:]) print (message.chat.id) # Команда /start @bot.message_handler(commands=['start']) def start(message): global par if avtor(message.chat.id)!=0: print (par) bot.send_message(message.chat.id, " Вы не авторизированны. Пройдите авторизацию командой /auth [пароль]", reply_markup=markup2) else: bot.send_message(message.chat.id, " Вы авторизированный пользователь. Наберите /help, для того, чтобы узнать список команд.") #Команда запроса помощи - /help @bot.message_handler(commands=['help']) def help(message): if avtor(message.chat.id)==0: mas=' Данный бот управляет теплицей на моём участке. \n Список команд для помощи, в управление этим ботом: \n Получить справку - /help \n Остальное всё управляется при помощи клавиатуры :)' bot.send_message(message.chat.id, mas, reply_markup=markup) print (message.chat.id, message.text) #Заменить интерфейс командной строки на клавиатуру @bot.message_handler(commands=['show']) def show(message): if avtor(message.chat.id)==0: mas='Клавиатура включена' bot.send_message(message.chat.id, mas, reply_markup=markup) print (message.chat.id, message.text) #получить температуру @bot.message_handler(regexp=" Прислать температуру") def temp(message): if avtor(message.chat.id)==0: tp=get_temp() mas=' Температура в теплице: '+str(tp)+'°C' bot.send_message(message.chat.id, mas) print (message.chat.id, message.text) #прислать снимок @bot.message_handler(regexp=" Прислать снимок") def photo(message): if avtor(message.chat.id)==0: path='/mnt/raw/photo/foto.jpg' #Путь к папку со снимком try: f = open(path, 'rb') #Открытия файла - снимка bot.send_photo(message.chat.id, f) #Отправка снимка print (message.chat.id, message.text) except: bot.send_message(message.chat.id, "Фоток нет :(") #Переход в меню окон @bot.message_handler(regexp=" Управление окнами") def windows(message): if avtor(message.chat.id)==0: print ("window") print (pos()) if str(pos())[0]=='1': bot.send_message(message.chat.id, "Ок", reply_markup=markup3)#Если автоматика включена, то выводим клавиатуру с надписью «Выключить автоматику» else: bot.send_message(message.chat.id, "Ок", reply_markup=markup4)#А здесь всё с точность наоборот #Кнопка назад @bot.message_handler(regexp=" Назад") def windows(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Ок", reply_markup=markup) #Выключение автоматики @bot.message_handler(regexp=" Выключить автоматику ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w')#Открываем файл f.write('30')#Пишем туда код команды, в данный момент это 30 f.close()#Закрываем файл k="No"#Дефолтное значение переменной while k[0:2]!="OK":#Проверяем ответ time.sleep(5)#Ждём 5 секунд f = open('/mnt/raw/wind')#Открываем файл k = f.read()#Читаем ответ f.close()#Закрывает print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup4) @bot.message_handler(regexp=" Включить автоматику ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('31') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup3) @bot.message_handler(regexp="️ Ручное управление") def windows(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Ок", reply_markup=markup5) @bot.message_handler(regexp="️ Назад") def windows(message): if avtor(message.chat.id)==0: if str(pos())[0]=='1': bot.send_message(message.chat.id, "Ок", reply_markup=markup3) else: bot.send_message(message.chat.id, "Ок", reply_markup=markup4) @bot.message_handler(regexp="️ Назад") def windows(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Ок", reply_markup=markup5) #Бегаем по меню @bot.message_handler(regexp=" Первое окно") def windows(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Ок", reply_markup=markup6) @bot.message_handler(regexp=" Второе окно") def windows(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Ок", reply_markup=markup7) @bot.message_handler(regexp="️ Открыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('11') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup6) @bot.message_handler(regexp="️ Закрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('10') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup6) @bot.message_handler(regexp=" Приоткрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('13') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup6) @bot.message_handler(regexp=" Призакрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('12') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup6) @bot.message_handler(regexp="️ Открыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('21') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup7) @bot.message_handler(regexp="️ Закрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('20') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup7) @bot.message_handler(regexp=" Приоткрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('23') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup7) @bot.message_handler(regexp=" Призакрыть окно ") def windows(message): if avtor(message.chat.id)==0: f = open('/mnt/raw/wind', 'w') f.write('22') f.close() k="No" while k[0:2]!="OK": time.sleep(5) f = open('/mnt/raw/wind') k = f.read() f.close() print(k[0:2]) bot.send_message(message.chat.id, "Успешно", reply_markup=markup7) #Реакция на команды, не приведённые выше @bot.message_handler(content_types=["text"]) def repeat_all_messages(message): if avtor(message.chat.id)==0: bot.send_message(message.chat.id, "Я не знаю такой команды. Набери /help, чтобы получить список команд") print (message.chat.id, message.text) #Отпрашиваем сервер на наличие новых сообщений if __name__ == '__main__': bot.polling()Не забываем указать здесь id датчика, chat-id и путь к разделу в оперативной памяти. Теперь у нас почти всё готово. Качаем этот дамп, и заливаем базу данных на свой сервер, и не забываем смонтировать раздел в оперативной памяти, думаю 10 МБ хватит по горло. Запускаем два наших скрипта-стартера и радуемся. Пароль по умолчанию: telbot. Меняем его в таблице tkey базы данных.
СМС информирование
Так же сделал СМС информирование на случай перегрева. Создаём файл sms.py:
#!/usr/bin/env python # -*- coding: utf8 -*- """ Автор Титов А.В. t_aleksandr_v@inbox.ru 17.02.2015 """ """ Скрипт предназначен для отправки СМС через сайт sms.ru """ """ Принимает следующие аргументы:""" """ -i или --idsender - id пользователя на sms.ru""" """ -t или --to - номер телефона получателя в формате 79219996660""" """ -s или --subject - текст сообщения на латинице""" from urllib2 import urlopen from optparse import OptionParser def sendsms(idsender,subject,to): subject = subject.replace(" ","+") url="http://sms.ru/sms/send?api_id=%s&text=%s&to=%s" %(idsender,subject,to) res=urlopen(url) if __name__ == '__main__': parser = OptionParser() parser.add_option("-i", "--ваш ключ", dest="idsender", default="ваш ключ", help="ID user on sms.ru", metavar="IDSENDER") parser.add_option("-t", "--ваш телефон", dest="to", default="ваш телефон", help="to telephone number", metavar="TO") parser.add_option("-s", "--temperatyra 32", dest="subject", default="Jara tut, otkroy okno", help="Name of subject", metavar="SUBJECT") (options, args) = parser.parse_args() sendsms(options.idsender,options.subject,options.to)Регистрируемся на sms.ru и берём так API-key в разделе для программистов. Так же не забываем указать в скрипте ваш номер телефона.
В программе для управления окон объявляем переменную:
Vr=0Затем вставляем в вечный цикл этот код:
d = datetime.today() V = d.strftime('%H') V = int(V) if (t2>32 and Vr!=V): print (V) Vr=V os.system('/home/samba/sms.py')В данный момент температура порога 32, смс будут отправляться в случае высокой температуры раз в час, пока она не спадёт.
P.S. В планах на будущее установить управляемый обогреватель и сделать автоматический полив.
Спасибо всем тем, кто дочитал до конца.
ссылка на оригинал статьи https://geektimes.ru/post/284258/
Добавить комментарий