AWS Step Functions - 将数据批量发送到子/嵌套 Step Functions 状态机

如何解决AWS Step Functions - 将数据批量发送到子/嵌套 Step Functions 状态机

我正在寻找一种方法，将数据从专利状态机批量发送到子状态机，一次 50 条记录。

我的意思是什么？

我有两个 AWS Step Functions 状态机。一个父级和一个子级状态机。父状态机的目的是从我们的 Jenkins 平台获取所有用户。它看起来像这样：

Comment: >-
  A state machine that coordinates the end-to-end process for Jenkins
StartAt: Get Jenkins Users
States:
  Get Jenkins Users:
    Type: Task
    Resource: "${JenkinsUsersFunctionArn}"
    TimeoutSeconds: 65
    HeartbeatSeconds: 30
    Retry:
      - ErrorEquals:
          - Lambda.ServiceException
          - Lambda.AWSLambdaException
          - Lambda.SdkClientException
          - States.Timeout
        IntervalSeconds: 2
        MaxAttempts: 3
        BackoffRate: 2
    Catch:
      - ErrorEquals:
          - States.ALL
        ResultPath: "$"
        Next: Process Error
    ResultPath: "$"
    Next: Filter Jenkins Users

这会输出一个对象数组，其中包含大约 1,500 个对象到 $.users 对象。

我想做的是将所有 1,500 个对象发送到子状态机的诗句，我想一次只发送 50 个。这意味着如果有 1,500 个对象，它总共会调用 30 个状态机。

我想出了这样的东西：

  Filter Jenkins Users:
    Type: Map
    InputPath: "$.users"
    MaxConcurrency: 50
    Iterator:
      StartAt: Filter
      States:
        Filter:
          Type: Task
          Resource: arn:aws:states:::states:startExecution
          Parameters:
            StateMachineArn:
            Input: 
              Users: "$"
              AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$: "$$.Execution.Id"
          End: true
    ResultPath: "$.users"
    Next: Success State

但这会同时启动 50 个状态机，这不是我想要的。我想批量发送 50 个对象到子状态机。

我为什么要这样做？

如果我要在一个状态机中处理所有这些，我会遇到很多限制，我正在尝试将其拆分为多个步进函数状态机以确保我不会达到任何限制。

这可能吗？

解决方法

{
  "users": [
    [
      50 users...
    ],[
      50 users...
    ],...
    [
      15 users...
    ]
  ]
}

  Filter Jenkins Users:
    Type: Map
    InputPath: "$.users"
    MaxConcurrency: 1
    Iterator:
      StartAt: Filter
      States:
        Filter:
          Type: Task
          Resource: arn:aws:states:::states:startExecution
          Parameters:
            StateMachineArn:
            Input: 
              Users: "$"
              AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$: "$$.Execution.Id"
          End: true
    ResultPath: "$.users"
    Next: Success State

Azure Functions ：如何使用本地调试模式将日志写入 Azure Application Insights 和 Azure Functions 使用 Python？

{
    "version": "2.0","logging": {
        "applicationInsights": {
            "samplingSettings": {
                "isEnabled": true,"excludedTypes": "Request"
            }
        }
    }
}

身体{
  背景颜色：浅蓝色；
}

h1 {
  白颜色;
  文本对齐：居中；
}

p {
  字体系列：verdana；
  字体大小：20px；
}

p {
  红色;
  文本对齐：居中；
}

p {
  文本对齐：居中；
  红色;
}