AWS IOT 错误:在 onclosenexttick 时过早关闭

Question

我正在尝试构建一个基本的AWS IOT Javascript应用程序，下面是源代码

var awsIot = require('aws-iot-device-sdk');
var device = awsIot.device({
keyPath: 'xxx-private.pem.key',
certPath: 'xxx-certificate.pem.crt',
caPath: 'AmazonRootCA1.pem',
clientId: 'xxx_policy',
host: 'xxxxx.amazonaws.com'
});
device.on('connect', function() {
console.log('connect');
//device.subscribe('topic_1');
device.publish('MyConnectPolicy', JSON.stringify({ test_data: 'NodeJS server connected...'}));
});
device.on('message', function(topic, payload) {
console.log('message', topic, payload.toString());
});

在运行这个项目时，我得到以下错误

events.js:200
throw er; // Unhandled 'error' event
^
Error: premature close
at onclosenexttick (xxx/node_modules/end-of-stream/index.js:54:86)
at processTicksAndRejections (internal/process/task_queues.js:76:11)
Emitted 'error' event on DeviceClient instance at:
at MqttClient. (xxx/node_modules/aws-iot-device-sdk/device/index.js:772:15)
at MqttClient.emit (events.js:228:7)
at TLSSocket.f (xxx/node_modules/once/once.js:25:25)
at onclosenexttick (xxx/node_modules/end-of-stream/index.js:54:73)
at processTicksAndRejections (internal/process/task_queues.js:76:11)

有人可以解决这个问题吗，提前谢谢。

Answer 1

我最近在尝试使用 AWS-IoT-SDK for node 连接到 AWS 上的thing时遇到了同样的问题。我终于在这个[Github问题][https://github.com/aws/aws-iot-device-sdk-js/issues/304#issuecomment-608500683]上找到了解决方案。

我没有在我的thing上附加政策.

要为您的thing创建新策略，您可以在创建事物或

In the left navigation pane, choose Secure, and then choose Policies. On the You don't have a policy yet page, choose Create a policy.
On the Create a policy page, in the Name field, enter a name for the policy (for example, MyIotPolicy). Do not use personally identifiable information in your policy names.

延伸阅读