HTTP Push 源

流 扫描表

NeuronEX 数据处理模块通过 HTTP Push 类型的数据源，可以在内部启动一个 HTTP 服务器，默认地址为http://0.0.0.0:10081，接收来自 HTTP 客户端的消息，在所有规则中都可以共用这个 HTTP Push数据源。该类型可以作为流、扫描表的数据源。

提示

当有任何使用 HTTP Push 源的规则启动后， HTTP 服务器才会启动运行，10081端口开启。当所有使用 httppush 源的规则都关闭后， HTTP 服务器会关闭运行，10081端口关闭。

如果使用 Docker 部署 NeuronEX，需要在 docker run 命令中添加 -p 10081:10081 参数，将容器内的 10081 端口映射到宿主机的 10081 端口后，才可正常使用 HTTP Push源 。

## run NeuronEX
$ docker run -d --name neuronex -p 8085:8085 -p 10081:10081 --log-opt max-size=100m emqx/neuronex:latest

创建流

登录 NeuronEX，点击数据处理 -> 源管理。在流管理页签，点击创建流。

在弹出的源管理 / 创建页面，进入如下配置：

• 流名称：输入流名称
• 是否为带结构的流：勾选确认是否为带结构的流，如为带结构的流，则需进一步添加流字段。可默认不勾选。
• 流类型：选择 httppush
• 数据源：指定 URL 的路径部分，例如 /api/data。

  提示

  httppush类型的数据源启动的 HTTP 服务器地址为http://0.0.0.0:10081，数据源（URL拼接路径） 填写为/api/data，则 HTTP 完整请求地址为：http://0.0.0.0:10081/api/data 。

• 配置组：可使用默认配置组，如希望自定义配置组，可点击添加配置组：
  • 名称：输入配置组名称。
  • 请求方法：HTTP 请求方法，可以是 POST 或 PUT。
• 流格式：支持 json、binary、protobuf、delimited、custom。默认 json 格式。
• 共享：勾选确认是否共享源。

创建扫描表

HTTP Push 源支持查询表。登录 NeuronEX，点击数据处理 -> 源管理。在扫描表页签，点击创建扫描表。

• 表名称：输入表名称
• 是否为带结构的表：勾选确认是否为带结构的表，如为带结构的表，则需进一步添加表字段。可默认不勾选。
• 表类型：选择 httppush。
• 数据源：指定 URL 的路径部分，与 URL 属性拼接成最终 URL， 例如 /api/data。
• 配置组：可使用默认配置组，如希望自定义配置组，可参考创建流部分。
• 表格式：支持 json、binary、protobuf、delimited、custom。默认 json 格式。
• 保留大小：指定保留大小。