定义Argo-Events传感器触发有效负载的键值对

Question

我试图用自定义键值对填充传感器Nats触发的有效负载。这些值不是依赖项的一部分。有人知道怎么做吗？

从医生那里：

Payload is the list of key-value extracted from an event payload to construct the request payload.

传感器定义：

apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
  name: minio-sensor
spec:
  dependencies:
    - name: test-dep
      eventSourceName: minio
      eventName: example
  triggers:
    - template:
        name: nats-trigger
        nats:
          # NATS Server URL
          url: nats.argo-events.svc:4222
          # Name of the subject
          subject: minio-events
          payload:
            - someKey: someValue
            - src:
                dependencyName: test-dep
                dataKey: notification.0.s3.object.key
              dest: fileName

Answer 1

终于找到了解决办法。实际上是两个。(最佳使用Argo-Events版本>= 1.6.0)

1. 为依赖项修改事件体.

apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
  name: minio-sensor
spec:
  dependencies:
    - name: test-dep
      eventSourceName: minio
      eventName: example
      transform:
        script: |-
          event.body.someKey='someValue'
          return event
  triggers:
    - template:
        name: nats-trigger
        nats:
          # NATS Server URL
          url: nats.argo-events.svc:4222
          # Name of the subject
          subject: minio-events
          payload:
            - src:
                dependencyName: test-dep
                dataKey: body.someKey
              dest: someKey
            - src:
                dependencyName: test-dep
                dataKey: notification.0.s3.object.key
              dest: fileName

1. 对不存在的路径使用默认值.

apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
  name: minio-sensor
spec:
  dependencies:
    - name: test-dep
      eventSourceName: minio
      eventName: example
  triggers:
    - template:
        name: nats-trigger
        nats:
          # NATS Server URL
          url: nats.argo-events.svc:4222
          # Name of the subject
          subject: minio-events
          payload:
            - src:
                dependencyName: test-dep
                dataKey: body.non-existing
                value: someValue
              dest: someKey
            - src:
                dependencyName: test-dep
                dataKey: notification.0.s3.object.key
              dest: fileName