BETA: This component is mostly stable but breaking changes could still be made outside of major version releases if a fundamental problem with the component is found.
Generates messages at a given interval using a Bloblang mapping executed without a context. This allows you to generate messages for testing your pipeline configs.
Introduced in version 3.40.0.
A bloblang mapping to use for generating messages.
The time interval at which messages should be generated, expressed either as a duration string or as a cron expression. If set to an empty string messages will be generated as fast as downstream services can process them.
An optional number of messages to generate, if set above 0 the specified number of messages is generated and then the input will shut down.
- Cron Scheduled Processing
- Generate 100 Rows
A common use case for the generate input is to trigger processors on a schedule so that the processors themselves can behave similarly to an input. The following configuration reads rows from a PostgreSQL table every 5 minutes.
The generate input can be used as a convenient way to generate test data. The following example generates 100 rows of structured data by setting an explicit count. The interval field is set to empty, which means data is generated as fast as the downstream components can consume it.