SELECT 和 WHERE 子句可用的字段
SELECT 和 WHERE 子句可用的字段与事件的类型相关。其中 clientid, username 和 event 是通用字段，每种事件类型都有。
普通主题 (消息发布)
| event | 事件类型，固定为 “message.publish” |
|---|
| id | MQTT 消息 ID |
| clientid | Client ID |
| username | 用户名 |
| payload | MQTT 消息体 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| flags | MQTT 消息的 Flags |
| headers | MQTT 消息内部与流程处理相关的额外数据 |
| timestamp | 事件触发时间 (ms) |
| publish_received_at | PUBLISH 消息到达 Broker 的时间 (ms) |
| node | 事件触发所在节点 |
$events/message_delivered (消息投递)
| event | 事件类型，固定为 “message.delivered” |
|---|
| id | MQTT 消息 ID |
| from_clientid | 消息来源 Client ID |
| from_username | 消息来源用户名 |
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| payload | MQTT 消息体 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| flags | MQTT 消息的 Flags |
| timestamp | 事件触发时间 (ms) |
| publish_received_at | PUBLISH 消息到达 Broker 的时间 (ms) |
| node | 事件触发所在节点 |
$events/message_acked (消息确认)
| event | 事件类型，固定为 “message.acked” |
|---|
| id | MQTT 消息 ID |
| from_clientid | 消息来源 Client ID |
| from_username | 消息来源用户名 |
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| payload | MQTT 消息体 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| flags | MQTT 消息的 Flags |
| timestamp | 事件触发时间 (ms) |
| publish_received_at | PUBLISH 消息到达 Broker 的时间 (ms) |
| node | 事件触发所在节点 |
$events/message_dropped (消息丢弃)
| event | 事件类型，固定为 “message.dropped” |
|---|
| id | MQTT 消息 ID |
| reason | 消息丢弃原因 |
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| payload | MQTT 消息体 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| flags | MQTT 消息的 Flags |
| timestamp | 事件触发时间 (ms) |
| publish_received_at | PUBLISH 消息到达 Broker 的时间 (ms) |
| node | 事件触发所在节点 |
$events/client_connected (终端连接成功)
| event | 事件类型，固定为 “client.connected” |
|---|
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| mountpoint | 主题挂载点(主题前缀) |
| peername | 终端的 IPAddress 和 Port |
| sockname | emqx 监听的 IPAddress 和 Port |
| proto_name | 协议名字 |
| proto_ver | 协议版本 |
| keepalive | MQTT 保活间隔 |
| clean_start | MQTT clean_start |
| expiry_interval | MQTT Session 过期时间 |
| is_bridge | 是否为 MQTT bridge 连接 |
| connected_at | 终端连接完成时间 (s) |
| timestamp | 事件触发时间 (ms) |
| node | 事件触发所在节点 |
$events/client_disconnected (终端连接断开)
| event | 事件类型，固定为 “client.disconnected” |
|---|
| reason | 终端连接断开原因 |
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| peername | 终端的 IPAddress 和 Port |
| sockname | emqx 监听的 IPAddress 和 Port |
| disconnected_at | 终端连接断开时间 (s) |
| timestamp | 事件触发时间 (ms) |
| node | 事件触发所在节点 |
$events/session_subscribed (终端订阅成功)
| event | 事件类型，固定为 “session.subscribed” |
|---|
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| timestamp | 事件触发时间 (ms) |
| node | 事件触发所在节点 |
$events/session_unsubscribed (取消终端订阅成功)
| event | 事件类型，固定为 “session.unsubscribed” |
|---|
| clientid | 消息目的 Client ID |
| username | 消息目的用户名 |
| peerhost | 客户端的 IPAddress |
| topic | MQTT 主题 |
| qos | MQTT 消息的 QoS |
| timestamp | 事件触发时间 (ms) |
| node | 事件触发所在节点 |
我的书签
添加书签
移除书签
