Compare commits
3 Commits
Author | SHA1 | Date |
---|---|---|
|
7d054dd291 | |
|
9ce89eded7 | |
|
4a52837287 |
12
main.py
12
main.py
|
@ -3,8 +3,8 @@ import uuid
|
|||
import time
|
||||
import json
|
||||
|
||||
sdtcloud = sdtcloudpubsub.sdtcloudpubsub()
|
||||
mqttClient = sdtcloud.setClient(f"device-app-{uuid.uuid1()}") # parameter is client ID(string)
|
||||
sdtcloudMqttClient = sdtcloudpubsub.sdtcloudpubsub()
|
||||
sdtcloudMqttClient.setClient(f"device-app-{uuid.uuid1()}") # parameter is client ID(string)
|
||||
|
||||
def read_json_file(file_path):
|
||||
with open(file_path, 'r', encoding='utf-8') as f:
|
||||
|
@ -17,7 +17,7 @@ def extract_data(json_item):
|
|||
return None
|
||||
|
||||
def main():
|
||||
file_path = '../cnt_data.json'
|
||||
file_path = './cnt_data.json'
|
||||
items = read_json_file(file_path)
|
||||
total_count = len(items)
|
||||
index = 0
|
||||
|
@ -25,9 +25,9 @@ def main():
|
|||
while True:
|
||||
data = extract_data(items[index])
|
||||
if data:
|
||||
msg = json.dumps(data, ensure_ascii=False, default=str)
|
||||
sdtcloud.pubMessage(mqttClient, msg)
|
||||
print(f"{time.strftime('%Y-%m-%d %H:%M:%S')} Extracted data:{msg}")
|
||||
# msg = json.dumps(data, ensure_ascii=False, default=str)
|
||||
sdtcloudMqttClient.pubMessage(data)
|
||||
print(f"{time.strftime('%Y-%m-%d %H:%M:%S')} Extracted data:{data}")
|
||||
else:
|
||||
print("No 'data' key found in the JSON item.")
|
||||
|
||||
|
|
Loading…
Reference in New Issue