Повышение стабильности при подключении к AWS IOT Core. - PullRequest
Новая
       166

Повышение стабильности при подключении к AWS IOT Core.

0 голосов
/ 21 июня 2020

Я пытаюсь использовать AWS IoT с Python. Я реализую клиент MQTT: 

#Exte codigo SOLO SIRVE para escritorio
#NO USARLO en una PYCOM

#
from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient 
from pathlib import Path
import time

#
cert_folder=Path("certificados")

# user specified callback function
def customCallback(client, userdata, message):
    print("Received a new message: ")
    print(message.payload)
    print("from topic: ")
    print(message.topic)
    print("--------------\n\n")

# AWS general configuration
AWS_PORT = 8883
AWS_HOST = '*****.amazonaws.com'
AWS_ROOT_CA = cert_folder / "*****.pem"
AWS_CLIENT_CERT = cert_folder / "*****.cert.pem"
AWS_PRIVATE_KEY = cert_folder / "*****.private.key"

# For certificate based connection
myMQTTClient = AWSIoTMQTTClient("Pycom-client")
# For Websocket connection
# myMQTTClient = AWSIoTMQTTClient("Pycom-client", useWebsocket=True)

# Configurations
# For TLS mutual authentication
myMQTTClient.configureEndpoint(AWS_HOST, 8883)
# For Websocket
# myShadowClient.configureEndpoint(AWS_HOST, 443)
myMQTTClient.configureCredentials(AWS_ROOT_CA, AWS_PRIVATE_KEY, AWS_CLIENT_CERT)
# For Websocket, we only need to configure the root CA
# myMQTTClient.configureCredentials(AWS_ROOT_CA)

myMQTTClient.configureOfflinePublishQueueing(-1)  # Infinite offline Publish queueing
myMQTTClient.configureDrainingFrequency(2)  # Draining: 2 Hz
myMQTTClient.configureConnectDisconnectTimeout(10)  # 10 sec
myMQTTClient.configureMQTTOperationTimeout(50)  # 5 sec

#
if myMQTTClient.connect():
    print('AWS connection succeeded')

myMQTTClient.publish("topic_1", "Hola AWS!!!", 0)

# Subscribe to topic
myMQTTClient.subscribe("topic_2", 1, customCallback)

myMQTTClient.disconnect()

#Ciclo principal
while True:

    myMQTTClient.connect()

    myMQTTClient.publish("topic_1", "Hola AWS!!!", 0)

    # Subscribe to topic
    myMQTTClient.subscribe("topic_2", 1, customCallback)

    myMQTTClient.disconnect()

Однако соединение по-прежнему очень нестабильно. Я очень часто получаю сообщения о тайм-ауте или отказе сервера. Я могу отправить пару сообщений и получить другие. Но получать сообщения по подписке сложно, и я не знаю, следует ли использовать дополнительный код, чтобы улучшить его.

1 Ответ

2 голосов
/ 25 июля 2020

Насколько я понимаю, вы хотите публиковать sh сообщения MQTT на AWS IoT Core со своего устройства, используя Python. Также вы хотите видеть опубликованные сообщения, подписавшись на соответствующие топи c. Основная проблема в вашем коде заключается в том, что вы не устанавливаете sh постоянный сеанс с AWS брокером сообщений IoT. В своем операторе while вы постоянно подключаетесь, публикуете sh, подписываетесь и отключаетесь.

Я бы рекомендовал вам обновить свой код следующим образом: 

# Connect and subscribe to AWS IoT
myMQTTClient.connect()
myMQTTClient.subscribe(your_topic_name, 1, customCallback)
time.sleep(1)
 
# Publish to the same topic in a loop forever
while True:
    myMQTTClient.publish(your_topic_name, "Hola AWS!!!", 0)
    time.sleep(1)

You не нужно myMQTTClient.disconnect() в этом примере, потому что у вас есть бесконечное while l oop.

...