Я младший программист на Python. Я хочу реализовать клиент MQTT для непрерывного получения и обработки сообщений:
records = []
def on_message(client, userdata, message):
payload = str(message.payload.decode("utf-8"))
records.append(payload)
...
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("XX.XX.XX.XX", XXXX, XX)
client.loop_forever()
# for r in records:
# do something with r
Когда клиент начинает получать полезную нагрузку, данные будут сохранены в списке записей . Другая функция будет (асинхронно или нет, либо Ok) получить доступ к этим данным в соответствии с последовательностью, которую они вводят в список records . Я понятия не имею, как реализовать это, или когда сообщение получено, оно будет обработано функцией. когда придет следующее сообщение, функция продолжит его обрабатывать и так далее.
Большое спасибо!