【发布时间】:2018-11-06 21:51:38
【问题描述】:
我们有一个将数据发布到 TCP 套接字的传感器。
我们如何在 CrateDB 中创建一个摄取规则以从该特定套接字读取?
我们是否需要使用 MQTT 从 Socket 读取数据,然后将其发布为主题,以便 CrateDB 摄取规则可以读取它?
这种方法听起来效率低下。我们想直接用来自 TCP 套接字的数据填充表。这可能吗?
【问题讨论】:
我们有一个将数据发布到 TCP 套接字的传感器。
我们如何在 CrateDB 中创建一个摄取规则以从该特定套接字读取?
我们是否需要使用 MQTT 从 Socket 读取数据,然后将其发布为主题,以便 CrateDB 摄取规则可以读取它?
这种方法听起来效率低下。我们想直接用来自 TCP 套接字的数据填充表。这可能吗?
【问题讨论】:
不,这目前在 CrateDB 中是不可能的。另请注意,CrateDB 中的 MQTT 实现已被弃用,并将在未来的版本中删除,https://crate.io/docs/crate/reference/en/latest/admin/ingestion/sources/mqtt.html。 主要原因是当前的实现非常有限(例如仅实现 MQTT 服务质量 (QoS) 一级),使用专用的 MQTT 摄取服务在规则定义和协议支持等方面更加灵活......
【讨论】: