random chars for queue name to avoid collisions on restart
This commit is contained in:
@@ -1,2 +1,3 @@
|
|||||||
venv/
|
venv/
|
||||||
__pycache__/
|
__pycache__/
|
||||||
|
.idea/
|
||||||
@@ -4,6 +4,7 @@ import sys
|
|||||||
import logging
|
import logging
|
||||||
import requests
|
import requests
|
||||||
from weather_utility import parse_weather_xml, publish_weather
|
from weather_utility import parse_weather_xml, publish_weather
|
||||||
|
import uuid
|
||||||
|
|
||||||
logging.basicConfig(
|
logging.basicConfig(
|
||||||
level=logging.INFO,
|
level=logging.INFO,
|
||||||
@@ -19,7 +20,8 @@ USER = "anonymous"
|
|||||||
PASSWORD = "anonymous"
|
PASSWORD = "anonymous"
|
||||||
EXCHANGE = "xpublic"
|
EXCHANGE = "xpublic"
|
||||||
|
|
||||||
QUEUE_NAME = "q_anonymous.subscribe.citypage.companyis2ari.ca"
|
rnd_6_chars = uuid.uuid4().hex[:6]
|
||||||
|
QUEUE_NAME = f"q_anonymous.subscribe.citypage.{rnd_6_chars}company2ari.ca"
|
||||||
SUBTOPIC = "#.WXO-DD.citypage_weather.ON.#"
|
SUBTOPIC = "#.WXO-DD.citypage_weather.ON.#"
|
||||||
|
|
||||||
def on_message(message):
|
def on_message(message):
|
||||||
|
|||||||
@@ -0,0 +1,8 @@
|
|||||||
|
amqp==5.3.1
|
||||||
|
certifi==2026.2.25
|
||||||
|
charset-normalizer==3.4.6
|
||||||
|
idna==3.11
|
||||||
|
paho-mqtt==2.1.0
|
||||||
|
requests==2.33.1
|
||||||
|
urllib3==2.6.3
|
||||||
|
vine==5.1.0
|
||||||
Reference in New Issue
Block a user