为什么我没有收到AWS Iot核心on_message回调

Question

我试图从aws上订阅的主题接收消息，我可以发布到该主题，但无法在paho mqtt应用程序上接收到消息。在AWS物联网客户端中，它工作得非常完美。

我的代码

import ssl

prefix = 'prefix'
uid = 'udi'
aws_region = 'us-west-2'
topic = 'node/test'

client_id = 'myNode'
device_cert = f'{prefix}-certificate.pem.crt'
device_privatekey = f'{prefix}-private.pem.key'
ca_cert = 'AmazonRootCA1.pem'
mqtt_url = f'{uid}.iot.{aws_region}.amazonaws.com'


def on_connect(client, userdata, flags, response_code):
    print(f"Connected with status: {response_code}")
    mqtt.subscribe(topic)

def on_disconnect(client, userdata, response_code):
    if response_code != 0:
        print(f"Unexpected disconnection. With Error code {response_code}")

def on_message(client, userdata, message):
    # print("Received message '" + str(message.payload) + "' on topic '"
    #     + message.topic + "' with QoS " + str(message.qos))
    print(message)

if __name__ == "__main__":
    print ("Loaded MQTT configuration information.")

    client = mqtt.Client(client_id=client_id, clean_session=True, userdata=None,
                        protocol=mqtt.MQTTv311, transport="tcp")

    client.tls_set(ca_cert,
                   certfile = device_cert,
                   keyfile = device_privatekey,
                   cert_reqs = ssl.CERT_REQUIRED,
                   tls_version = ssl.PROTOCOL_TLSv1_2,
                   ciphers = None)

    client.tls_insecure_set(False)
    client.on_connect = on_connect
    client.on_message = on_message

    print ("Connecting to AWS IoT Broker...")
    client.connect(mqtt_url, port = 8883, keepalive=60)
    client.loop_forever()

我的物联网地址：{“版本”：“2012-10-17”，“html" target="_blank">声明”：[{“效果”：“允许”，“行动”：“物联网”，“资源”：“arn:aws:iot:us-west-2:account_-id:client/myNode”}，{“效果”：“允许”，“行动”：“允许”，“行动”：“iot:Subscribe”，“资源”：“arn:aws:iot:us-west-2:account_-id:topicfilter/node/test”}，{“效果”：“允许”，“行动”：“物联网：接收”，“资源”：”：“arn:aws:iot:us-west-2:account\u id:topic/node/test”}]}

为了安全起见我没有显示我的ACCOUNT_ID前缀和UID

Answer 1

在on_connect（）回调mqtt.subscribe（主题）中，可能应该是client.subscribe（主题）