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
源 。
bash
## 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 格式。
- 保留大小:指定保留大小。