如何传递或解析从 argo 工作流生成的资源事件源主体？

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《如何传递或解析从 argo 工作流生成的资源事件源主体？》，聊聊，我们一起来看看吧！

我有一个资源传感器来触发一个工作流程，该工作流程报告导致该事件的原始工作流程 - 一种记录器。 在传感器的参数中，我想获取原始工作流程的主体，以便从中提取某些值 - 目前我计划简单地将整个 json 作为输入字符串传递。

当工作流程不平凡并且包含变量文件时，就会出现问题，例如：

apiversion: argoproj.io/v1alpha1
kind: workflow
metadata:
  generatename: test-es-workflow-
  labels:
    class: dummy-in
spec:
  entrypoint: whalesay
  arguments:
    parameters:
      - name: message
        value: hello world
  templates:
    - name: whalesay
      inputs:
        parameters:
          - name: message
      container:
        image: docker/whalesay:latest
        command: [cowsay]
        args: ["{{inputs.parameters.message}}"]

当发生这种情况时，触发的工作流程：

apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
  name: demo-sensor
spec:
  template:
    serviceAccountName: operate-workflow-sa
  dependencies:
    - name: test-dep-sensor
      eventSourceName: demo-wf-submit
      eventName: demo-log
  triggers:
    - template:
        name: argo-workflow
        k8s:
          operation: create
          source:
            resource:
              apiVersion: argoproj.io/v1alpha1
              kind: Workflow
              metadata:
                generateName: demo-log-
              spec:
                entrypoint: demolog
                arguments:
                  parameters:
                    - name: body
                      value: hello world
                templates:
                - name: demolog
                  inputs:
                    parameters:
                      - name: body
                  container:
                    image: demolog:latest
                    imagePullPolicy: "Always"
                    command: [/app/demoapp.py]
                    args: ["-j", "{{inputs.parameters.body}}"]
          parameters:
            - src:
                dependencyName: test-dep-sensor
                dataKey: body
                value: wow! a default value
              dest: spec.arguments.parameters.0.value
      retryStrategy:
        steps: 3

失败，并显示消息 message：无效规范：templates.demolog：无法解析 {{inputs.parameters.message}}

如果工作流不包含任何变量（{{}} 中没有包含任何变量），则触发的工作流将按预期执行。

我很乐意弄清楚如何获得以下任何或所有解决方案：

1. 警告变量无法解析并替换 null
2. 不要解析事件正文中的变量，即将其呈现为纯字符串
3. 在创建事件时解析变量，以便可以解析正文

环境： 库伯内特斯：v1.20.15； 阿尔戈：v3.2.9； 阿尔戈活动：v1.6.3

正确答案

我开发了类型 2 的答案，即渲染用双花括号括起来的变量。 它并不优雅，但似乎有效：

使用 jq 修补传感器的依赖项部分，以用其他内容替换双花括号（我选择“%%”）

dependencies:
    - name: test-dep-sensor
      eventSourceName: demo-wf-submit
      eventName: demo-log
      transform:
        jq: 'walk( if type=="string" then gsub("{{";"%%") else . end ) | walk( if type=="string" then gsub("}}";"%%") else . end )'

其他信息：

Argo Events Transformations in sensors

jq manual

本篇关于《如何传递或解析从 argo 工作流生成的资源事件源主体？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！