SELECT 和 WHERE 子句可用的字段
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 |
事件触发所在节点 |