使用“资源”模板/步骤和“获取”操作在 Argo 工作流程中提取资源并传递到下游步骤？

Question

我正在探索一种在 Argo 工作流程中读取 K8S 资源的简单方法。当前文档主要关注有条件的创建/补丁（https://argoproj.github.io/argo/examples/#kubernetes-resources），而我很好奇是否可以执行“action: get”，额外资源状态（或完整资源）的一部分，并将其作为工件或结果输出传递给下游。有任何想法吗？

Answer 1

更新：

action: get现在支持： https: //github.com/argoproj/argo-workflows/blob/246d4f44013b545e963106a9c43e9cee397c55f7/examples/k8s-wait-wf.yaml#L46

原答案：

action: get不是 Argo 提供的功能。

kubectl然而，它很容易在 Pod 中使用，然后将 JSON 输出发送到输出参数。这使用 BASH 脚本将 JSON 发送到result输出参数，但显式输出参数或输出工件也是可行的选择。

apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  generateName: kubectl-bash-
spec:
  entrypoint: kubectl-example
  templates:
  - name: kubectl-example
    steps:
    - - name: generate
        template: get-workflows
    - - name: print
        template: print-message
        arguments:
          parameters:
          - name: message
            value: "{{steps.generate.outputs.result}}"
  - name: get-workflows
    script:
      image: bitnami/kubectl:latest
      command: [bash]
      source: |
        some_workflow=$(kubectl get workflows -n argo | sed -n 2p | awk '{print $1;}')
        kubectl get workflow "$some_workflow" -n argo -ojson
  - name: print-message
    inputs:
      parameters:
      - name: message
    container:
      image: alpine:latest
      command: [sh, -c]
      args: ["echo result was: '{{inputs.parameters.message}}'"]

请记住，它将kubectl使用工作流的 ServiceAccount 的权限运行。请务必使用有权访问您想要获取的资源的ServiceAccount 提交工作流。