文档中心

概述

工作流开始运行时，会接收用户指定的输入数据，并将数据传递至工作流的开始节点，即 start 所指向的节点。在后续的执行中，每个节点都接收上一个节点的输出作为自己的输入，并在执行结束后，继续将自己的输出传给下一个节点。所有的输入输出数据均为 JSON 格式。本节将为您介绍如何处理节点的输入输出数据。

工作流的输入与输出

• workflow 的输入由用户提供，如果用户未提供输入，那么使用 "{}" 作为默认输入。
• workflow 的输出是最后一个节点的输出。

节点的输入与输出

workflow 的输入作为 start 节点的输入，当一个节点执行结束后，它的输出会成为下一个节点的输入。

节点可以通过 stateDataFilter 处理上一个节点传入的输入数据，和传给下一个节点的输出数据。operation 节点还可以通过 actionDataFilter 定义调用云函数时的输入，和处理云函数的返回结果，比如把节点输入数据的其中一部分作为 payload 去调用云函数，云函数返回结果后只取出其中的一部分放入节点数据里。

stateDataFilter 和 actionDataFilter 都是节点的可选参数，节点若不定义则不对输入输出做其它处理。

stateDataFilter

示例:

工作流的定义如下

name: demo start: hello description: "从输入数据中取出 apple 对应的值" states: - type: 

wait name: hello stateDataFilter: input: ".fruits" output: "{res: .apple}" seconds: 2 end: true

假定工作流的输入数据为

{ "fruits": { "apple": 7, "banana": 10 }, "vegetables": ["potato", "tomato", "carrot"] }

工作流的处理流程如下：

1、收到执行请求和输入数据，找到开始节点 hello，将数据传递给 hello；

2、hello 根据 stateDataFilter 的 input 参数处理输入数据，处理结果作为自己节点数据，结果为

{ "apple": 7, "banama" : 10 }

3、hello 节点执行 wait 逻辑，等待2秒钟；

4、hello 节点操作结束，根据 stateDataFilter 的 output 参数处理输出数据，结果为

{ "res": 7 }

5、由于 hello 节点之后没有其它节点，因次 hello 执行结束后整个工作流就结束了，工作流的输出即上一步中的结果。

actionDataFilter

在 operation 节点中调用函数计算等公有云服务时，可以通过这个 filter 定义传给云服务的参数，也能对服务返回的结果进一步提取筛选，并加入到节点数据中。

示例：

name: demo start: hello description: "从输入数据中取出 apple 对应的值" states: - type:

 operation name: hello actionDataFilter: fromStateData: "{ stateInput: .hello }" results:

 "[ .breads[0], .pasta[1] ]" toStateData": ".itemsToBuyAtStore" resource: "brn:cfc:bj

:123456:function:test:$LATEST" end: true 

假定本次工作流的输入为{"hello":"world"}，函数的返回为

{ "breads": ["baguette", "brioche", "rye"], "pasta": [ "penne", "spaghetti", "ravioli"] }

那么工作流的处理流程大致如下：

1、收到执行请求和输入数据，找到开始节点 hello，将输入数据 {"hello":"world"} 传递给 hello；

2、hello 节点内没有定义 stateDataFilter，因此不执行输入预处理；

3、hello 节点内定义了 actionDataFilter，根据 fromStateData 参数执行数据处理，得到 {"stateInput": "world"}；

4、hello 节点将上一步得到的结果作为 payload 去调用函数；

5、函数返回结果后，根据 actionDataFilter 的 results 参数处理函数返回，结果为 ["baguette", "spaghetti"]；

6、根据 actionDataFilter 的 toStateData 参数继续处理，把 results 的结果放到节点数据的 itemsToBuyAtStore 字段（没有则创建），最终节点数据为

{ "hello": "world", "itemsToBuyAtStore": ["baguette", "spaghetti"] }

7、hello 节点内没有定义 stateDataFilter，因此不执行输出预处理，工作流执行结束。

jq 表达式

从上文的介绍中可知，节点数据的过滤、处理都依靠 jq 表达式，这里展示出常用的 jq 操作。源数据如下：

{
    "store": {
        "book": [ 
          { 
            "category": "reference",
            "author": "Nigel Rees",
            "title": "Sayings of the Century",
            "price": 8.95
          },
          { 
            "category": "fiction",
            "author": "Evelyn Waugh",
            "title": "Sword of Honour",
            "price": 12.99
          },
          { 
            "category": "fiction",
            "author": "Herman Melville",
            "title": "Moby Dick",
            "isbn": "0-553-21311-3",
            "price": 8.99
          },
          { 
            "category": "fiction",
            "author": "J. R. R. Tolkien",
            "title": "The Lord of the Rings",
            "isbn": "0-395-19395-8",
            "price": 22.99
          }
        ],
        "bicycle": {
          "color": "red",
          "price": 19.95
        }
     }
}

各类操作结果如下：

jq 是一个功能强大的、用于解析 json 数据的工具，关于 jq 的更多用法，您可参考

jq 官网

jqplay（jq在线调试）