Argo Events Kubernetes Automation

Event Source → Sensor → Trigger → Action
(GitHub webhook)  (filter)  (fire)   (Argo Workflow, K8s Job, HTTP call)

kubectl create namespace argo-events
kubectl apply -n argo-events -f \
  https://raw.githubusercontent.com/argoproj/argo-events/stable/manifests/install.yaml

apiVersion: argoproj.io/v1alpha1
kind: EventSource
metadata:
  name: github-webhook
  namespace: argo-events
spec:
  webhook:
    push:
      port: "12000"
      endpoint: /push
      method: POST

apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
  name: deploy-on-push
  namespace: argo-events
spec:
  dependencies:
    - name: push-event
      eventSourceName: github-webhook
      eventName: push
      filters:
        data:
          - path: body.ref
            type: string
            value:
              - "refs/heads/main"
  triggers:
    - template:
        name: run-deploy-workflow
        argoWorkflow:
          operation: submit
          source:
            resource:
              apiVersion: argoproj.io/v1alpha1
              kind: Workflow
              metadata:
                generateName: deploy-
              spec:
                entrypoint: deploy
                arguments:
                  parameters:
                    - name: commit
                      value: ""
                templates:
                  - name: deploy
                    container:
                      image: myorg/deployer:latest
                      command: ["./deploy.sh"]
                      args: ["{{inputs.parameters.commit}}"]
          parameters:
            - src:
                dependencyName: push-event
                dataKey: body.after
              dest: spec.arguments.parameters.0.value

apiVersion: argoproj.io/v1alpha1
kind: EventSource
metadata:
  name: s3-uploads
spec:
  s3:
    new-data:
      bucket:
        name: raw-data
      events:
        - s3:ObjectCreated:*
      filter:
        suffix: ".csv"
      endpoint: minio.storage:9000
      insecure: true
      accessKey:
        name: minio-creds
        key: accesskey
      secretKey:
        name: minio-creds
        key: secretkey

apiVersion: argoproj.io/v1alpha1
kind: EventSource
metadata:
  name: kafka-events
spec:
  kafka:
    orders:
      url: kafka-broker.messaging:9092
      topic: order-events
      consumerGroup:
        groupName: argo-events
      jsonBody: true

apiVersion: argoproj.io/v1alpha1
kind: EventSource
metadata:
  name: scheduled
spec:
  calendar:
    nightly-report:
      schedule: "0 2 * * *"
      timezone: "Europe/Rome"
    weekly-cleanup:
      schedule: "0 4 * * 0"
      timezone: "Europe/Rome"

spec:
  dependencies:
    - name: tests-passed
      eventSourceName: ci-webhook
      eventName: tests
      filters:
        data:
          - path: body.status
            type: string
            value: ["success"]
    - name: security-scan
      eventSourceName: ci-webhook
      eventName: security
      filters:
        data:
          - path: body.status
            type: string
            value: ["clean"]
  triggers:
    - template:
        name: deploy-after-checks
        conditions: "tests-passed && security-scan"
        # Only triggers when BOTH events have fired