id: datagen_person_realtime_trigger_json
namespace: com.example.datagen

tasks:
  - id: log
    type: io.kestra.plugin.core.log.Log
    message: "Created: {{ trigger.value.name }} ({{ trigger.value.email }})!"

triggers:
  - id: datagen
    type: io.kestra.plugin.datagen.core.RealtimeTrigger
    throughput: 10
    reportingInterval: PT5S
    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() }}"