DataFlow 将结果集输出到 MQTT topic 队列中。
配置方法:
xml
<target type="mqtt"
table_name="result_join"
client_id="spark-streaming-mqtt-tid"
host="localhost"
port="1883"
write_type="JSON"
user_name="name" password="password"
fields="test_id,test_name,created_at"
topic="testtopic" />
字段说明:
- write_type 将结果以 JSON 形式写入到 exchange;支持 STRING 和 JSON 两种,STRING 则需要 delimiter 分隔符支持;
- client_id MQTT 客户端标识,唯一 ID 即可;
- user_name 和 password 是可选的,MQTT 如果有认证,则需要;
- topic 发送到 MQTT 的 Topic 名称;