Telegram bot для наших bmw G серии

Итак, однажды мне пришла мысль сделать что-то большее, чем доступно в официальном myBMW приложении. В приложении все вроде ок, но чувство добавить чего-то своего не покидало меня. Немного покопавшись в могучем и необъятном интернете нашел библиотеку bimmerconnected на Github. Каково было мое удивление, что достать данные со своих авто оказалось не очень сложно. С этого и начался мой долгий и упорный труд небольшой оптимизации под себя моих же авто, а точнее их информационной составляющей. Прошу не пинать меня за предоставленный код ниже, я не являюсь серьезным программистом, а всего лишь занимаюсь АСУТП.

Для чего мне это?

Изучив доступные возможности библиотеки bimmerconnected я понял, что мне нужно получать уведомление в телегу о следующем:

• остатке топлива в баке, чтобы супруга раз в день получала сообщения о необходимости дозаправке, если топливо в ее авто почти на нуле (менее 10 литров).

• периодического фонового уведомления о локации авто по точкам. Допустим, супруга покинула квартиру, хочу получить уведомление, приехала к детскому садику - хочу получить уведомление, машина на даче - уведомление и тп. Мне так проще жить, когда вижу где авто и не мучаю тупыми вопросами супругу).

• считыванием текущих ошибок прямо в телегу. Спустило колесо или вылезла та или иная ошибка - получил уведомление в телегу. Я не всегда нахожусь рядом с авто и работа вахтой наложила свои ограничения на мониторинг моих двух авто.

• логировании сообщений, телега удобна именно тем, что спустя время легко найти что и когда появлялось, когда авто требовала замены масла в двигателе или тормозной жидкости и т. п.

Общая концепция

Общая схема работы сервиса следующая поэтапно следующая:

• скачиваем данные с BMW connected drive и сохраняем SQLite DB. Для этого будем использовать отмеченную выше bimmerconnected библиотеку

• Запускать данный процесс будем на VPS сервере, допустим, раз в 30 минут.

• далее делаем telegram bot, который будет отправлять уведомления пользователю или же обрабатывать запросы от пользователя и точно также запускаем бота на VPS сервере.

Первый этап

Устанавливаем sqlite3, asyncio и bimmer_connected.

Для этого в командной строке вводим pip install bimmer_connected, pip install asyncio и pip install sqlite3.

Далее надо знать VIN номер авто и данные учетной записи connected drive. Для тестирования соединения пишем код ниже на питоне и смотрим результат.

import asyncio 
from bimmer_connected.account import MyBMWAccount 
from bimmer_connected.api.regions import Regions 
async def main(): 
  account=MyBMWAccount('USER','PASSWORD',Regions.REST_OF_WORLD) 
  await account.get_vehicles() 
  vehicle=account.get_vehicle('VIN') 
  print(vehicle.brand,vehicle.name,vehicle.vin,vehicle.mileage)
  result1=vehicle.fuel_and_battery
  print(result1)

  result2=vehicle.vehicle_location
  print(result2)

  result2 = vehicle.vehicle_location
  latitude1 = result2.location.latitude
  longitude1 = result2.location.longitude

  print("Latitude:", latitude1)
  print("Longitude:", longitude1)
  fuel_value = result1.remaining_fuel.value
  print("Fuel value:", fuel_value)
  print("Mileage:", vehicle.mileage.value)
  
asyncio.run(main())

Вместо USER, PASSWORD и VIN соответственно надо подставить данные своего авто.

Далее получаем успешный ответ:

Далее для сохранения в sqlite дописываем код следующим образом.

import sqlite3 
import asyncio 
from bimmer_connected.account import MyBMWAccount 
from bimmer_connected.api.regions import Regions 
async def main(): 
  account=MyBMWAccount('USER','PASSWORD',Regions.REST_OF_WORLD) 
  await account.get_vehicles() 
  vehicle=account.get_vehicle('VIN') 
  print(vehicle.brand,vehicle.name,vehicle.vin,vehicle.mileage) 
  print(result1)
  result2=vehicle.vehicle_location
  print(result2)
  # Получение локации
  result2 = vehicle.vehicle_location
  latitude1 = result2.location.latitude
  longitude1 = result2.location.longitude
  print("Latitude:", latitude1)
  print("Longitude:", longitude1)
  fuel_value = result1.remaining_fuel.value
  print("Fuel value:", fuel_value)
  print("Mileage:", vehicle.mileage.value)
  # Подключение к базе данных
  conn = sqlite3.connect('mydatabase.db')
  cursor = conn.cursor()

  # Создание таблицы (если она еще не существует)
  cursor.execute('''CREATE TABLE IF NOT EXISTS BMW
                    (id INTEGER PRIMARY KEY AUTOINCREMENT,
                     latitude FLOAT,
                     longitude FLOAT,
                     fuel FLOAT,
                     km FLOAT)''')

  # Вставка данных в таблицу
  latitude = latitude1
  longitude = longitude1
  fuel = fuel_value
  km = vehicle.mileage.value

  cursor.execute('INSERT INTO BMW (latitude, longitude, fuel, km) VALUES (?, ?, ?, ?)', (latitude, longitude, fuel, km))

  # Сохранение изменений в базе данных
  conn.commit()

  # Закрытие соединения
  conn.close()
asyncio.run(main())

Теперь данные выгружаются с сервера BMW в нашу пока еще локальную базу данных sqlite. Продолжение следует...