55 lines
1.4 KiB
Python
55 lines
1.4 KiB
Python
import os, sys
|
|
import logging
|
|
DEBUG = os.environ.get('DEBUG')
|
|
logging.basicConfig(stream=sys.stdout,
|
|
format='[%(asctime)s] %(levelname)s %(module)s/%(funcName)s - %(message)s',
|
|
level=logging.DEBUG if DEBUG else logging.INFO)
|
|
|
|
import time
|
|
import json
|
|
|
|
import asyncio
|
|
from aiomqtt import Client
|
|
|
|
async def manage_bluetooth():
|
|
while True:
|
|
await asyncio.sleep(1)
|
|
|
|
|
|
async def process_bluetooth_command(topic, text):
|
|
logging.info('Bluetooth command: %s', text)
|
|
pass
|
|
|
|
async def process_mqtt(message):
|
|
text = message.payload.decode()
|
|
topic = message.topic.value
|
|
logging.debug('MQTT topic: %s, message: %s', topic, text)
|
|
|
|
if topic.startswith('iot/12ser/bluetooth'):
|
|
await process_bluetooth_command(topic, text)
|
|
else:
|
|
logging.debug('Invalid topic, returning')
|
|
return
|
|
|
|
async def fetch_mqtt():
|
|
await asyncio.sleep(3)
|
|
|
|
async with Client(
|
|
hostname='10.55.0.106',
|
|
port=1883,
|
|
) as client:
|
|
await client.subscribe('iot/12ser/#')
|
|
async for message in client.messages:
|
|
loop = asyncio.get_event_loop()
|
|
loop.create_task(process_mqtt(message))
|
|
|
|
|
|
if __name__ == '__main__':
|
|
logging.info('')
|
|
logging.info('==========================')
|
|
logging.info('Booting up...')
|
|
|
|
loop = asyncio.get_event_loop()
|
|
a = loop.create_task(manage_bluetooth())
|
|
loop.run_until_complete(fetch_mqtt())
|