Node.js SDK Access Example

Updated on 2024-11-06 GMT+08:00

View PDF

This topic describes how to use a Node.js AMQP SDK to connect to the Huawei Cloud IoT platform and receive subscribed messages from the platform.

Development Environment

Node.js 8.0.0 or later is used. Download it from the Node.js official website. After installation, run the following command to check the version:

node --version

If the version is displayed and is later than 8.0.0, the installation is successful.

Sample Code

Create a JavaScript file (for example, HwIotAmqpClient.js) on the local computer and save the following sample code to the file. Modify related connection parameters by referring to AMQP Client Access.

const container = require('rhea');
// Obtain the timestamp.
var timestamp = Math.round(new Date());

// Set up a connection.
var connection = container.connect({
     // Access domain name. For details, see AMQP Client Access.
     'host': '${UUCID}.iot-amqps.cn-north-4.myhuaweicloud.com',
     'port': 5671,
     'transport': 'tls',
     'reconnect': true,
     'idle_time_out': 8000,
     // Method to assemble username. For details, see AMQP Client Access.
      'username': 'accessKey=${yourAccessKey}|timestamp=' + timestamp + '|instanceId=${instanceId}',
     // accessCode. For details, see AMQP Client Access.
     'password': '${yourAccessCode}',
     'saslMechannisms': 'PLAIN',
     'rejectUnauthorized': false,
     'hostname': 'default',
});

// Create a Receiver connection. You can use DefaultQueue.
var receiver = connection.open_receiver('${yourQueue}');

// Callback function for receiving messages pushed from the cloud
container.on('message', function (context) {
     var msg = context.message;
     var content = msg.body;
     console.log(content);
     // Send an ACK message. Note that the callback function should not contain time-consuming logic.
     context.delivery.accept();
 });

Go to the directory where the HwIotAmqpClient.js file is located and run the following command to install the rhea library:
```
npm install rhea
```
After installation, the project files shown in the following figure are displayed.
Run the following command to start the AMQP client:
```
node HwIotAmqpClient.js
```
Running result examples

Successful subscription:
If the following log information is displayed, the AMQP client successfully subscribes to the IoT platform and obtains data from the platform.
Failed subscription:
The following log indicates that the AMQP client authentication fails on the IoT platform. Check whether the access code is correct and whether the difference between the timestamp and the standard time is greater than 5 minutes.

Parent topic: AMQP Data Forwarding

Previous topic: Java SDK Access Example

Next topic: C# SDK Access Example

Feedback

Was this page helpful?

Helpful Not helpful

Provide feedback

Thank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.

The system is busy. Please try again later.

Which of the following issues have you encountered?

Content is inconsistent with the product UI

Unclear descriptions

Lack of examples or code

Incorrect steps

Can't find what I need

Lack of best practices

Feedback (optional)

0/500

Select at least one type of issue, and enter your comments or suggestions.

Enter a maximum of 500 characters.

Submit Cancel

For any further questions, feel free to contact us through the chatbot.

Chatbot