PutDruidRecord

概述

将记录发送到Druid并创建索引。

通过API将数据流异步发送到Druid的索引任务。如果需要聚合和汇总数据，则需要提供《JSON聚合器设置》。有关如何使用JSON描述聚合的详细信息 ，可查看： http://druid.io/docs/latest/querying/aggregations.html

PutDruidRecord属性说明

记录读取 ： 指定用于解析输入数据的读取服务并需要提供数据的Schema信息。

记录输出 ：指定用于将数据序列化的输出服务

Tranquility服务 ： 用于发送到Druid的Tranquility服务, 即DruidTranquilityController。

示例

例子中，我们将样本数据Json建索到Druid。

#####样本数据

{"name":"张三","age":"18"}

#####设置

根据处理的上级数据的格式需要配置记录读取的类型，比如这里上级是Json数据，配置JsonTreeReader。

配置记录输出，将输出数据转化为指定的Record格式输出到下级数据流。

设置"Tranquility服务"，具体访问Druid服务的接口和纬度字段等，都需要在该控制器服务中设置。

流程模板

参见附件(请右键另存保存)：PutDruidRecord示例