跳到主要内容
版本:Next
generateINPUTBUFFERPROCESSOROUTPUT

生成(Generate)

生成输入(Input)以固定的时间间隔产生合成文本消息(Message),主要用于测试、演示和基准测试。每次读取返回 batch_size 份相同的 context 字符串。

配置​

FieldTypeRequiredDefault描述
typestringyes—常量值 "generate"
contextstringyes—每条消息的载荷文本
intervaldurationyes—两次读取之间的间隔,如 1ms、1s、1m(首次读取立即执行)
countintegerno—消息总数;达到后返回 EOF。未设置表示无限制
batch_sizeintegerno1每次读取返回的消息数

示例​

input:
type: "generate"
context: '{ "timestamp": 1625000000000, "value": 10, "sensor": "temp_1" }'
interval: 1ms
batch_size: 1000
count: 10000