请教一下，如何通过EMQX的API向EMQX的主题推送消息？

Lee 2024-10-13 21:29:35

我试过将鉴权认证放在明道云里不行，自己直接吧用户名和密码用 basic 编码了一下，直接传 Authorization 参数里。

我试过将鉴权认证放在明道云里不行，自己直接吧用户名和密码用 basic 编码了一下，直接传 Authorization 参数里。

闪电 2024-10-12 11:53:54

请教一下这里是怎么设置的？ [图片]

请教一下这里是怎么设置的？

Lee 2024-06-30 23:16:04

多谢大神指导，现在已经实现了通过 API 向 EMQX 推送数据，并且在昆仑通态触摸屏上实现数据交互，这样在通过 webhok 就可以实现数据双向的流通了，不过触摸屏 MQTT 局限还是传输汉字的时候不能成功，只能传输英语字符和数字，然后 200 块钱买个科星的 TTL 转语音，通过 python 代码块向设备推送文本，实现了语音播报，这样每笔订单都能播报客户某某某，下单什么货多少数量，如果有想这么搞的，可以多交流。

多谢大神指导，现在已经实现了通过 API 向 EMQX 推送数据，并且在昆仑通态触摸屏上实现数据交互，这样在通过 webhok 就可以实现数据双向的流通了，不过触摸屏 MQTT 局限还是传输汉字的时候不能成功，只能传输英语字符和数字，然后 200 块钱买个科星的 TTL 转语音，通过 python 代码块向设备推送文本，实现了语音播报，这样每笔订单都能播报客户某某某，下单什么货多少数量，如果有想这么搞的，可以多交流。

夕 2024-07-08 18:51:21

我也买了个科信的 ttl，发送的文本内容是什么呢？直接发汉字貌似不能播放，用他的软件转成 modbus rtu 协议 GB2312 码，也没播放啊。谢谢了

我也买了个科信的 ttl，发送的文本内容是什么呢？直接发汉字貌似不能播放，用他的软件转成 modbus rtu 协议 GB2312 码，也没播放啊。谢谢了

mj4ever 2024-06-25 17:42:31

Authoration 可以用明道的组件去获取，也可以自己写代码块实现 // 用户名和密码 const username = 'yourusername' ; const password = 'yourpassword' ; // 将用户名和密码合并，并编码为 Base64 const authorization = Buffer . from ( `{username}:{password}` ). toString ( 'base64' ); output = { authorization : authorization } 另外，这个是 Linux 的命令行去获取的方式， echo -n "yourusername:yourpassword" | base64 方式有很多

Authoration 可以用明道的组件去获取，也可以自己写代码块实现

// 用户名和密码

const username = 'yourusername';

const password = 'yourpassword';

// 将用户名和密码合并，并编码为 Base64
const authorization = Buffer.from(`{username}:{password}`).toString('base64');

output = {
    authorization: authorization
}

另外，这个是 Linux 的命令行去获取的方式，echo -n "yourusername:yourpassword" | base64

方式有很多

mj4ever 2024-06-25 17:42:31

Authoration 可以用明道的组件去获取，也可以自己写代码块实现 // 用户名和密码 const username = 'yourusername' ; const password = 'yourpassword' ; // 将用户名和密码合并，并编码为 Base64 const authorization = Buffer . from ( `{username}:{password}` ). toString ( 'base64' ); output = { authorization : authorization } 另外，这个是 Linux 的命令行去获取的方式， echo -n "yourusername:yourpassword" | base64 方式有很多

Authoration 可以用明道的组件去获取，也可以自己写代码块实现

// 用户名和密码

const username = 'yourusername';

const password = 'yourpassword';

// 将用户名和密码合并，并编码为 Base64
const authorization = Buffer.from(`{username}:{password}`).toString('base64');

output = {
    authorization: authorization
}

另外，这个是 Linux 的命令行去获取的方式，echo -n "yourusername:yourpassword" | base64

方式有很多

mj4ever 2024-06-20 10:57:37

这个是 HTTP 的方式，确实比较简单 先去 MQTT 系统中，创建一个 API [图片] 这里用 postman 测试了下，可以正常发送指令 [图片]

这个是 HTTP 的方式，确实比较简单
先去 MQTT 系统中，创建一个 API

这里用 postman 测试了下，可以正常发送指令

mj4ever 2024-06-20 10:57:37

这个是 HTTP 的方式，确实比较简单 先去 MQTT 系统中，创建一个 API [图片] 这里用 postman 测试了下，可以正常发送指令 [图片]

这个是 HTTP 的方式，确实比较简单
先去 MQTT 系统中，创建一个 API

这里用 postman 测试了下，可以正常发送指令

野猪向前冲 2024-06-19 22:08:35

不需要这么麻烦的，直接代码块给 emqx 发 payload 消息就完事了。

不需要这么麻烦的，直接代码块给 emqx 发 payload 消息就完事了。

mj4ever 2024-06-19 10:59:06

如果你对容器中的目录不是很确定时，可以登录到容器中，进行查看 docker exec -it script_command_1 bash ls /usr/local/node-20.11/

如果你对容器中的目录不是很确定时，可以登录到容器中，进行查看
docker exec -it script_command_1 bash
ls /usr/local/node-20.11/

mj4ever 2024-06-18 10:32:33

可以现在 nodejs 的环境下进行测试，然后再考虑迁移到 mingdao 代码块的环境 vscode + nodejs 就可以了 [图片]

可以现在 nodejs 的环境下进行测试，然后再考虑迁移到 mingdao 代码块的环境
vscode + nodejs 就可以了

mj4ever 2024-06-18 09:41:39

参考了 如何在 Node.js 项目中使用 MQTT ，基本实现了通过按钮控制智能开关的打开和关闭。 在 mingdao 中使用代码块实现上述逻辑，需要引入 mqtt 模块，需要参考 mingdao 的这一篇 如何扩展代码块依赖库 还需要注意，下载 mqtt 模块，需要高版本的 nodejs，需要将 registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-command:node1018-python36 升级到 registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-command:node2011-python312 以下是代码块中的代码 /** * 数字孪生智慧楼宇-下发指令-下发指令给MQTT * @author zxm * @version 1.0 * @date 2024-06-14 * @memo 注意 output 的位置，且 client.on 里面的 console.log 都要注释，否则会报错 '程序返回值序列化失败' */ const mqtt = require ( 'mqtt' ); const mqttUrl = input . mqttUrl ; const devEUI = input . devEUI ; const type = input . type ; const data = input . data ; // 创建客户端实例 const options = { clean : true , connectTimeout : 4000 , // 认证信息 clientId : 'emqx_mingdao' , // username: '', // password: '', }; // 定义返回结果 let ret = { "status" : 0 , "msg" : "成功" , "data" : "" }; // 定义 topic const topic = '/milesight/downlink/' + devEUI ; // 组装 message let message_data = "" ; if ( type === "智能移动插座" ) { // 打开 { "confirmed": true, "data": "CAEA/w==", "fPort": 85 } // 关闭 { "confirmed": true, "data": "CAAA/w==", "fPort": 85 } if ( data === "开" ) { message_data = "CAEA/w==" ; } else if ( data === "关" ) { message_data = "CAAA/w==" ; } else { ret . status = 2 ; ret . msg = "失败，指令错误" ; ret . data = "传入的指令未配置，请检查，devEUI: " + devEUI + " type: " + type + " data: " + data ; } } else { ret . status = 1 ; ret . msg = "失败，分类未配置" ; ret . data = "传入的分类未配置，请检查，devEUI: " + devEUI + " type: " + type + " data: " + data ; }; const message = `{ "confirmed": true, "data": " ${ message_data } ", "fPort": 85 }` ; const client = mqtt . connect ( mqttUrl , options ); // 当连接成功时触发，参数为 connack // 消息发布 client . on ( 'connect' , () => { // console.log('Connected'); client . publish ( topic , message , { qos : 0 , retain : false }, ( error ) => { if ( error ) { // console.error(error); } }); client . end (); }); // 在断开连接以后触发 client . on ( 'close' , function () { // console.log('Disconnected'); // output = ret; 放到此处，会报错 'output is not defined at api' }); // output 此行代码放在代码块中执行，会优先完成 // 但上述业务代码也只有两种情况，执行成功，或者是执行超时，如果超时，代码块是会报错的 // 所以，整体来看，要么必定返回 { status: 0, msg: '成功', data: '' } 要么，代码块执行超时 output = ret ; // console.log('output', output);

参考了如何在 Node.js 项目中使用 MQTT，基本实现了通过按钮控制智能开关的打开和关闭。

在 mingdao 中使用代码块实现上述逻辑，需要引入 mqtt 模块，需要参考 mingdao 的这一篇如何扩展代码块依赖库

还需要注意，下载 mqtt 模块，需要高版本的 nodejs，需要将 registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-command:node1018-python36 升级到 registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-command:node2011-python312

以下是代码块中的代码

/**
 * 数字孪生智慧楼宇-下发指令-下发指令给MQTT
 * @author zxm
 * @version 1.0
 * @date 2024-06-14
 * @memo 注意 output 的位置，且 client.on 里面的 console.log 都要注释，否则会报错 '程序返回值序列化失败'
 */

const mqtt = require('mqtt');

const mqttUrl = input.mqttUrl;
const devEUI = input.devEUI;
const type = input.type;
const data = input.data;

// 创建客户端实例
const options = {
    clean: true,
    connectTimeout: 4000,
    // 认证信息
    clientId: 'emqx_mingdao',
    // username: '',
    // password: '',
};

// 定义返回结果
let ret = {
    "status": 0,
    "msg": "成功",
    "data": ""
};

// 定义 topic
const topic = '/milesight/downlink/' + devEUI;

// 组装 message
let message_data = "";
if (type === "智能移动插座") {
    // 打开 { "confirmed": true, "data": "CAEA/w==", "fPort": 85 }
    // 关闭 { "confirmed": true, "data": "CAAA/w==", "fPort": 85 }
    if (data === "开") {
        message_data = "CAEA/w==";
    } else if (data === "关") {
        message_data = "CAAA/w==";
    } else {
        ret.status = 2;
        ret.msg = "失败，指令错误";
        ret.data = "传入的指令未配置，请检查，devEUI: " + devEUI + " type: " + type + " data: " + data;
    }
} else {
    ret.status = 1;
    ret.msg = "失败，分类未配置";
    ret.data = "传入的分类未配置，请检查，devEUI: " + devEUI + " type: " + type + " data: " + data;
};

const message = `{ "confirmed": true, "data": "${message_data}", "fPort": 85 }`;

const client = mqtt.connect(mqttUrl, options);  // 当连接成功时触发，参数为 connack


// 消息发布
client.on('connect', () => {
    // console.log('Connected');
    client.publish(topic, message, { qos: 0, retain: false }, (error) => {
        if (error) {
            // console.error(error);
        }
    });
    client.end();
});

// 在断开连接以后触发
client.on('close', function () {
    // console.log('Disconnected');
    // output = ret;   放到此处，会报错 'output is not defined at api'
});

// output 此行代码放在代码块中执行，会优先完成
// 但上述业务代码也只有两种情况，执行成功，或者是执行超时，如果超时，代码块是会报错的
// 所以，整体来看，要么必定返回 { status: 0, msg: '成功', data: '' } 要么，代码块执行超时
output = ret;
// console.log('output', output);