generate_input.md

generate_input operator

The generate_input operator generates log entries with a static record. This is useful for testing pipelines, especially when coupled with the rate_limit operator.

Configuration Fields

Field	Default	Description
id	generate_input	A unique identifier for the operator
output	Next in pipeline	The connected operator(s) that will receive all outbound entries
write_to	$	A field that will be set to the path of the file the entry was read from
entry		A entry log entry to repeatedly generate
count	0	The number of entries to generate before stopping. A value of 0 indicates unlimited
static	false	If true, the timestamp of the entry will remain static after each invocation

Example Configurations

Mock a file input

Configuration:

- type: generate_input
  entry:
    record:
      message1: log1
      message2: log2

Output records:

{
  "record": {
    "message1": "log1",
    "message2": "log2"
  },
},
{
  "record": {
    "message1": "log1",
    "message2": "log2"
  },
},
...