能力说明
能力名称:历史数据补取【内部专用】
该能力是为"全网历史关键词"和"全网历史判定图"两个能力在成功跑完历史回溯后,由于画布空闲被释放等意外事件,造成没有取到历史数据的情况准备的。
功能简介
使用该能力前,需要知道历史任务的任务号,当"全网历史关键词"和"全网历史判定图"成功创建任务并运行后,在能力方框内会有显示。
该能力可以取出指定任务号的历史数据。
配置参数
| 参数名称 | 参数类型 | 是否必填 | 默认值 | 参数说明 |
|---|---|---|---|---|
| 订阅topic | 文本 | 是 | 订阅topic | |
| 订阅tag | 文本 | 是 | 内部根据任务号查询到的tag值 | |
| 消费方式 | 文本 | 是 | 从尾开始 | 消费方式 |
| 是否需要解压 | 文本 | 是 | 需要 | 是否需要解压 |
| 高级配置 | 文本 | 是 | json | 主要用于配置时间范围 |
使用步骤
- 将"全网历史关键词"和"全网历史判定图"界面上的任务号记下来
- 到后台通过任务号查询到该任务的unique_tag(操作方法后面有)
- 能力配置:订阅topic = LazyLableForNifi
- 能力配置:订阅tag=上一步得到的unique_tag
- 能力配置:消费方式=从指定时间开始
- 能力配置:是否需要解压=需要
- 能力配置:估计一下之前历史任务的启动时间,能早几分钟别晚了,填入高级配置,例如 {"subscribe_start_time":"2020-01-01 12:13:14"}
- 启动任务,等待
后台查询tag的方法
- 瑞云平台 -> 数据标引 -> 数据中心工作流(正式)-> 搜索任务号
- 点击任务详情 -> 点击”任务desc“
- 在弹出的配置中,搜索”mapred.nifi.info.proc.unique_tag“,复制其中的值即可
输入简介
起点能力,无输入
输出简介
同"全网历史关键词"和"全网历史判定图"
输出数据样例
无