无法使用 AWSIoTPythonSDK 通过 MQTT 连接到 AWS IoT Core

Question

我已一步步按照AWS教程进行操作。 https://aws.amazon.com/premiumsupport/knowledge-center/iot-core-publish-mqtt-messages-python/

我创建了带有 * 的开放式策略，注册了一个事物并将其附加到策略，生成、下载并激活了证书。我尝试使用适用于 Python v2 的 AWS IoT 开发工具包和原始 SDK 连接并发布到订阅，但都不起作用。我使用的代码直接来自 AWS 的演示示例连接代码，但它们就是无法连接。

使用适用于 Python v2 的 AWS IoT 开发工具包时，我收到此错误消息：

RuntimeError: 1038 (AWS_IO_FILE_VALIDATION_FAILURE): A file was read and the input did not match the expected value

使用原始 SDK 时，我收到此错误消息：

TimeoutError: [Errno 60] Operation timed out

我正在使用的Python代码：

# Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
# SPDX-License-Identifier: MIT-0

import time as t
import json
import AWSIoTPythonSDK.MQTTLib as AWSIoTPyMQTT

# Define ENDPOINT, CLIENT_ID, PATH_TO_CERT, PATH_TO_KEY, PATH_TO_ROOT, MESSAGE, TOPIC, and RANGE
ENDPOINT = "XXXXX-ats.iot.ap-southeast-2.amazonaws.com"
CLIENT_ID = "testDevice"
PATH_TO_CERT = "certs/XXXX-certificate.pem.crt"
PATH_TO_KEY = "certs/XXXX-private.pem.key"
PATH_TO_ROOT = "certs/root.pem"
MESSAGE = "Hello World"
TOPIC = "test/testing"
RANGE = 20

myAWSIoTMQTTClient = AWSIoTPyMQTT.AWSIoTMQTTClient(CLIENT_ID)
myAWSIoTMQTTClient.configureEndpoint(ENDPOINT, 8883)
myAWSIoTMQTTClient.configureCredentials(PATH_TO_ROOT, PATH_TO_KEY, PATH_TO_CERT)

myAWSIoTMQTTClient.connect()
print('Begin Publish')
for i in range (RANGE):
    data = "{} [{}]".format(MESSAGE, i+1)
    message = {"message" : data}
    myAWSIoTMQTTClient.publish(TOPIC, json.dumps(message), 1) 
    print("Published: '" + json.dumps(message) + "' to the topic: " + "'test/testing'")
    t.sleep(0.1)
print('Publish End')
myAWSIoTMQTTClient.disconnect()

（我审查了端点和证书 ID）

（我使用的是 MacBook Air 并在公立学校网络上）

Answer 1

我回家测试了一下，效果很好。如果您遇到同样的问题，请尝试对网络进行故障排除。我认为我的学校阻止了 MQTT 或其他东西。

Answer 2

MQTT 使用特定端口号 8883，您将在 myAWSIoTMQTTClient.configureEndpoint(ENDPOINT, 8883) 中配置该端口号。

在我的一门 AWS IOT 课程中，我了解到一些网络管理员会阻止所有不常用的端口，以避免不必要的流量，而 MQTT 是 IOT 行业特有的东西。这可能就是为什么当您在学校网络中尝试时它不起作用，而当您在家里尝试时却起作用的原因。

Answer 3

我已将 OpenSSL 版本更改为 1.1.1 并创建了设备证书，但它没有抛出此消息。如果您使用的是 OpenSSL 3.x，您可以尝试使用 OpenSSL 1.1.1