Update main.py
This commit is contained in:
parent
4a52837287
commit
9ce89eded7
6
main.py
6
main.py
|
@ -3,8 +3,8 @@ import uuid
|
||||||
import time
|
import time
|
||||||
import json
|
import json
|
||||||
|
|
||||||
sdtcloud = sdtcloudpubsub.sdtcloudpubsub()
|
sdtcloudMqttClient = sdtcloudpubsub.sdtcloudpubsub()
|
||||||
mqttClient = sdtcloud.setClient(f"device-app-{uuid.uuid1()}") # parameter is client ID(string)
|
sdtcloudMqttClient.setClient(f"device-app-{uuid.uuid1()}") # parameter is client ID(string)
|
||||||
|
|
||||||
def read_json_file(file_path):
|
def read_json_file(file_path):
|
||||||
with open(file_path, 'r', encoding='utf-8') as f:
|
with open(file_path, 'r', encoding='utf-8') as f:
|
||||||
|
@ -26,7 +26,7 @@ def main():
|
||||||
data = extract_data(items[index])
|
data = extract_data(items[index])
|
||||||
if data:
|
if data:
|
||||||
msg = json.dumps(data, ensure_ascii=False, default=str)
|
msg = json.dumps(data, ensure_ascii=False, default=str)
|
||||||
sdtcloud.pubMessage(mqttClient, msg)
|
sdtcloudMqttClient.pubMessage(msg)
|
||||||
print(f"{time.strftime('%Y-%m-%d %H:%M:%S')} Extracted data:{msg}")
|
print(f"{time.strftime('%Y-%m-%d %H:%M:%S')} Extracted data:{msg}")
|
||||||
else:
|
else:
|
||||||
print("No 'data' key found in the JSON item.")
|
print("No 'data' key found in the JSON item.")
|
||||||
|
|
Loading…
Reference in New Issue