dani/bite
1
0
Fork 0
mirror of https://github.com/daniviga/bite.git synced 2025-02-19 23:06:03 +01:00
Code Releases Activity

Use shared subscription

Browse Source
This commit is contained in:
Daniele Viganò 2020-06-16 23:09:14 +02:00
parent 2a443815b0
commit 32b6350c35
Signed by: dani
GPG Key ID: DB49AFC03C40EE02
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
freedcs/telemetry/management/commands/mqtt-to-db.py
View File

@ -32,7 +32,8 @@ class Command(BaseCommand):
async def mqtt_broker(self): async def mqtt_broker(self):
async with Client(MQTT_HOST, port=MQTT_PORT) as client: async with Client(MQTT_HOST, port=MQTT_PORT) as client:
await client.subscribe("#") # use shared subscription for HA/balancing
await client.subscribe("$share/telemetry/#")
async with client.unfiltered_messages() as messages: async with client.unfiltered_messages() as messages:
async for message in messages: async for message in messages:
payload = json.loads(message.payload.decode('utf-8')) payload = json.loads(message.payload.decode('utf-8'))