condition-sample.yaml

# 任务参数配置
app:
  logger: "DEBUG"               # 日志模式
  lang: "zh-CN"                 # zh-CN/en
  source:
    kafka-bootstrap: "localhost:9093"
  job:
    parallelism:
      default: 2
      max: 100
    checkpoint:
      interval: 5000
      storage: "/event-senses-bot/log/checkpoint"
    filter:
      enabled: true
      max-cache-expire: 300
  sink:
    parallelism: 2
    backup: "/event-senses-bot/log/backup"
    cache:
      max-queue: 5
      interval-millis: 5000
  db:
    redis:
      cluster-enabled: false
      cluster-nodes:
      host: localhost
      port: 6379
      username:
      password:
      database: 0
      pool:
        max-total: 20
        max-idle: 8
        min-idle: 0
        max-wait-millis: 3000
    clickhouse:
      jdbc: "jdbc:clickhouse://localhost:8123/event_senses_bot"
      username:
      password:

# 事件配置
event:
  name: "自定义条件动作事件示例"
  code: "EVENT-5C0595EFEAA9"
  catalog: "TEST"
  desc: "这是一个事件示例"

# 事件渠道配置
channel:
  name: "测试事件渠道"
  code: "CHANNEL-88DD8E18EAC7"
  topic: "event_sense_topic"
  format: "JSON"
  groupId: "event_sense_group1"
  encryption:
    type: "TEXT"
    key: ""
  params:
    - { param: "uid", filter: true, nullable: true, datatype: "STRING", desc: "UID" }
    - { param: "test_value", datatype: "DOUBLE", desc: "测试值" }
    - { param: "test_text", datatype: "STRING", desc: "测试文本" }

# 流水线配置
actions:
  - action:
      name: "自定义条件动作示例"
      code: "ACTION-4DA81C62898B"
      desc: ""
      type: "CONDITION"
      parent: "0"
      config:
        condition:
          expression: "${test_value > 100}"
          truly: "<NEXT-ACTION-CODE>"
          falsely: "<NEXT-ACTION-CODE>"