能力说明
能力名称:流式数据输入接口
功能简介
该能力需要与APIv5的/data_stream/send_to_queue配套使用
接口说明请参考https://api.hylanda.com/v5/help/doc/web/#42
该能力作为外部数据流和画布数据流的桥梁,可以将外部数据引入画布内。
当客户端向上述接口发送数据后,数据会被缓存到内部的一个数据队列中,该能力的功能就是从这个数据队列中读取并输出数据。
简单的说,当客户调用上述接口发送了一条数据后,这条数据会通过内部的流程,从这个能力输出出来。
流式数据的内部数据队列会定期清理,最近6小时的会保留,此外的数据不保证一直存储,请发送接口后及时使用能力读出并处理。
配置参数
| 参数名称 | 参数类型 | 是否必填 | 默认值 | 参数说明 |
|---|---|---|---|---|
| appkey | 文本 | 是 | * | 申请APIv5使用权限时分配给客户的appkey |
| 消费方式 | 文本 | 是 | 从尾开始 | 消费RMQ数据的方式,默认消费最新 |
| 订阅起始时间 | 文本 | 否 | yyyy-MM-dd hh:mm:ss | 选择按时间消费时的必填项 |
说明:能力启动过一次后,只能按照当前选择的消费方式消费,要想切换消费方式请重新拉一个能力
输入简介
该能力不需要输入
输入数据样例
无
输出简介
订阅到的数据
输出数据样例
无
相关能力
无
参考指标
数据质量:99.9%
处理性能:8k/分钟
- 测试环境
| CPU | 内存 | 线程数 |
|---|---|---|
| 4核 | 4g | 4 |
- 效率
| 运行时间 | 处理条数 |
|---|---|
| 前5分钟 | 处理37136条 |
| 第10分钟 | 处理66009 |
| 第15分钟 | 处理10w |
附加说明
无
隐藏参数说明
无