Change broker's IP address
This commit is contained in:
parent
7d5d68e29c
commit
1e87df0b7a
2
main.py
2
main.py
|
@ -84,7 +84,7 @@ async def process_mqtt(message):
|
||||||
|
|
||||||
async def fetch_mqtt():
|
async def fetch_mqtt():
|
||||||
await asyncio.sleep(3)
|
await asyncio.sleep(3)
|
||||||
async with Client('192.168.0.100') as client:
|
async with Client('192.168.0.106') as client:
|
||||||
async with client.filtered_messages('iot/cameras') as messages:
|
async with client.filtered_messages('iot/cameras') as messages:
|
||||||
await client.subscribe('#')
|
await client.subscribe('#')
|
||||||
async for message in messages:
|
async for message in messages:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user