
Generate
Generate
yaml
type: "io.kestra.plugin.datagen.core.Generate"Examples
yaml
id: datagen_person_json
namespace: com.example.datagen
tasks:
- id: datagen
type: io.kestra.plugin.datagen.core.Generate
generator:
type: io.kestra.plugin.datagen.generators.JsonObjectGenerator
locale: ["fr", "FR"]
value:
name: "#{name.fullName}"
email: "#{internet.emailAddress}"
age: 30
address:
city: "#{address.city}"
zip: "#{address.zipCode}"
skills: [ "#{job.keySkills}", "#{job.position}", "hardcoded" ]
ts: "{{ now() }}"
- id: log
type: io.kestra.plugin.core.log.Log
message: "Created: {{ outputs.datagen.value.name }} ({{ outputs.datagen.value.email }})!"
yaml
id: datagen_person_json_batch
namespace: com.example.datagen
tasks:
- id: datagen
type: io.kestra.plugin.datagen.core.Generate
batchSize: 100
store: true
generator:
type: io.kestra.plugin.datagen.generators.JsonObjectGenerator
locale: ["fr", "FR"]
value:
name: "#{name.fullName}"
email: "#{internet.emailAddress}"
age: 30
address:
city: "#{address.city}"
zip: "#{address.zipCode}"
skills: [ "#{job.keySkills}", "#{job.position}", "hardcoded" ]
ts: "{{ now() }}"
- id: log
type: io.kestra.plugin.core.log.Log
message: "Created: {{ outputs.datagen.value.name }} ({{ outputs.datagen.value.email }})!"
yaml
id: datagen_person_csv
namespace: com.example.datagen
inputs:
- id: rows
type: INT
displayName: "Number of Rows"
description: "Number of data rows to generate (excluding header)."
defaults: 10
- id: separator
type: STRING
displayName: "Separator"
description: "Column separator character (e.g., ',', ';')."
defaults: ","
- id: header
type: BOOL
displayName: "Include header"
description: "Include header row in the CSV output."
defaults: true
tasks:
- id: datagen
type: io.kestra.plugin.datagen.core.Generate
generator:
type: io.kestra.plugin.datagen.generators.StringValueGenerator
locale: ["en", "US"]
value: |
#{csv '{{ inputs.separator }}','"','{{inputs.header}}','{{ inputs.rows}}','name_column','#{Name.first_name}','last_name_column','#{Name.last_name}'}
- id: log
type: io.kestra.plugin.core.log.Log
message: |
{{ outputs.datagen.value }}
Properties
generator*RequiredNon-dynamic
Definitions
JSON Object Generator
type*Requiredobject
value*Requiredobject
localearray
SubTypestring
Random Bytes Generator
type*Requiredobject
sizeinteger
Default
0String Value Generator
type*Requiredobject
value*Requiredstring
localearray
SubTypestring
batchSizeintegerstring
Default
1storebooleanstring
Default
falseOutputs
countinteger
sizeinteger
uristring
Format
uri