云工作流：任务步骤

参数说明

任务（Task）步骤定义了函数计算服务的函数调用信息，执行任务步骤会调用相应的函数。

任务步骤包含以下属性：

• type：task表示该步骤是任务步骤。
• name：步骤名称。
• resourceArn：资源标识，当前支持函数、消息队列、Serverless 工作流流程，例如acs:fc:cn-shanghai:18807708****3420:services/fnf_test/functions/hello。更多信息，请参见服务集成。
• 可选：pattern：集成服务的执行模式，不同的集成服务支持不同的执行模式。默认值为requestResponse，枚举值如下：
  • requestResponse：同步等待任务执行结束后继续该步骤。
  • sync：异步提交任务后，等待任务执行结束，获得任务返回结果后继续该步骤。
  • waitForCallback：异步提交任务后（例如完成函数调用后）当前步骤暂停，直到收到关于该任务的回调或该任务超时。
• 可选：timeoutSeconds：任务超时时间。如果任务执行超过指定的超时时间，则任务步骤执行超时。
• 可选：end：当前步骤结束后是否继续执行其后定义的步骤。
• 可选：inputMappings：输入映射。任务步骤的输入会被用作函数调用的event，更多信息，请参见InvokeFunction。
• 可选：outputMappings：输出映射。其中的$local是函数调用的返回结果，其格式必须是JSON类型。
  说明 如果未指定输出映射，本步骤默认将$local作为输出。
• 可选：errorMappings：错误映射。本映射仅在步骤执行出错，且配置catch时生效。可以通过$local.cause及$local.error将错误信息映射至输出，并传递给下个步骤。
  说明 $local.error及$local.code为系统预留字段，mapping中的source字段必须取这两个值，详细信息，请参见本文示例。另外，errorMappings为可选字段，如果未指定则发生错误后无法在下一步骤获取相关错误信息。
• retry：定义了一组重试策略，其中每一个重试策略包含以下属性：
  • errors：定义了一个或者多个错误，更多信息，请参见错误定义。
  • intervalSeconds：重试的初始间隔时间，最大值是86400秒，默认值是1秒。
  • maxIntervalSeconds：重试的最长间隔时间，最大值和默认值是86400秒。
  • maxAttempts：最多重试次数，默认值是3次。
  • multiplier：后一次重试比前一次重试间隔时间的倍数，默认值是2。
• catch：定义了一组捕获策略，其中每一个捕获策略包含如下属性：
  • errors：定义了一个或者多个错误，详情请参见下面表格。
  • goto：跳转目的步骤名称。
    说明 该目的步骤只能是和当前任务步骤并列的一个步骤。

示例

• 简单任务步骤

  下面的示例流程包含一个任务步骤。

  • 如果流程的输入是{"name": "function flow"}，输出是{"hello": "function flow"}。
  • 如果流程没有指定输入或者输入不包含name key，则任务步骤执行失败，从而导致整个流程执行失败。
  • 流程定义

    version: v1
    type: flow
    steps:
      - type: task
        name: hello
        resourceArn: acs:fc:{region}:{accountID}:services/fnf_test/functions/hello           

    resourceArn的参数说明如下：

    • {region}：需替换成您选择的地域，例如cn-shanghai。
    • {accountID}：需替换成您的账号ID。您可以在Serverless工作流控制台的流程页面，单击右上角的头像查看，如下图所示。
  • 函数定义

    import json
    
    class MyError(Exception):
      pass
    
    def handle(event, context):
      evt = json.loads(event)
      if "name" in evt:
        return {
          "hello": evt["name"]
        }
      else:
        raise MyError("My unhandled exception")          

• 错误重试

  下面的示例会重试MyError。如果流程没有指定输入或者输入不包含name key，Serverless 工作流服务会根据重试策略多次重试失败任务调用。

  • 在第一次发生错误后等待3秒，然后再次调用函数。
  • 在第二次发生错误后等待6秒（intervalSeconds x multiplier），然后再次调用函数。
  • 在第三次发生错误后等待12秒（intervalSeconds x multiplier x multiplier），然后再次调用函数。
  • 经过三次重试后，函数仍然返回错误，重试次数超过maxAttempts，任务步骤失败，流程以失败结束。

  version: v1
  type: flow
  steps:
    - type: task
      name: hello
      resourceArn: acs:fc:{region}:{accountID}:services/fnf_test/functions/hello
      retry:
        - errors:
          - MyError
          intervalSeconds: 3
          maxAttempts: 3
          multiplier: 2            

• 错误捕获

  下面的示例会对捕获MyError，然后跳转到final步骤。由于错误被成功捕获，最后流程以成功结束。

  version: v1
  type: flow
  steps:
    - type: task
      name: hello
      resourceArn: acs:fc:{region}:{accountID}:services/fnf_test/functions/hello
      catch:
        - errors:
          - MyError
          goto: final
    - type: pass
      name: pass1
    - type: pass
      name: final           

• 带错误映射的错误捕获

  下面的示例会对MyError捕获，然后跳转到final步骤。由于进行了错误映射，可以在final步骤中获取错误信息并进行处理。最后流程以成功结束。当然，您也可以将该步骤的输入、常量等在errorMappings中进行输出映射。

  version: v1
  type: flow
  steps:
    - type: task
      name: hello
      resourceArn: acs:fc:{region}:{accountID}:services/fnf_test/functions/hello
      errorMappings:
        - target: errMsg
          source: $local.cause #该值为系统预留，在本步骤发生错误时可直接使用
        - target: errCode
          source: $local.error #该值为系统预留，在本步骤发生错误时可直接使用
      catch:
        - errors:
          - MyError
          goto: final
    - type: pass
      name: pass1
    - type: pass
      name: final  

  映射后在进入final步骤的event中将看到EventDetail为如下内容：

  "EventDetail": "{\"input\":{},\"local\":{\"errorCode\":\"MyError\",\"errorMsg\":\"some message\"}}",