ItemBatcher (Karte)

Gibt die maximale Anzahl von Elementen an, die jede untergeordnete Workflow-Ausführung verarbeitet. Der Interpreter begrenzt die Anzahl der im Items Array gebündelten Elemente auf diesen Wert. Wenn Sie sowohl eine Chargennummer als auch eine Größe angeben, reduziert der Interpreter die Anzahl der Elemente in einem Stapel, um zu verhindern, dass die angegebene Stapelgrößenbeschränkung überschritten wird.

Wenn Sie diesen Wert nicht angeben, sondern einen Wert für die maximale Batchgröße angeben, verarbeitet Step Functions in jeder untergeordneten Workflow-Ausführung so viele Elemente wie möglich, ohne die maximale Batchgröße in Byte zu überschreiten.

Stellen Sie sich beispielsweise vor, Sie führen eine Ausführung mit einer JSON Eingabedatei aus, die 1130 Knoten enthält. Wenn Sie für jeden Stapel einen maximalen Artikelwert von 100 angeben, erstellt Step Functions 12 Stapel. Davon enthalten 11 Stapel jeweils 100 Artikel, während der zwölfte Stapel die restlichen 30 Artikel enthält.

Alternativ können Sie die maximale Anzahl von Elementen für jeden Stapel als Referenzpfad zu einem vorhandenen Schlüssel-Wert-Paar in Ihrer Statuseingabe für Distributed Map angeben. Dieser Pfad muss in eine positive Ganzzahl aufgelöst werden.

Beispielsweise angesichts der folgenden Eingabe:

{
  "maxBatchItems": 500
}

Sie können die maximale Anzahl der zu stapelnden Elemente mithilfe eines Referenzpfads wie folgt angeben:

{
  ...
  "Map": {
    "Type": "Map",
    "MaxConcurrency": 2000,
    "ItemBatcher": {
      "MaxItemsPerBatchPath": "$.maxBatchItems"
    }
    ...
    ...
  }
}

Gibt die maximale Größe eines Batches in Byte an, bis zu 256KBs. Wenn Sie sowohl eine maximale Chargennummer als auch eine maximale Stapelgröße angeben, reduziert Step Functions die Anzahl der Artikel in einem Stapel, um zu verhindern, dass die angegebene Stapelgrößenbeschränkung überschritten wird.

Alternativ können Sie die maximale Batchgröße als Referenzpfad zu einem vorhandenen Schlüssel-Wert-Paar in Ihrer Distributed Map-Statuseingabe angeben. Dieser Pfad muss in eine positive Ganzzahl aufgelöst werden.

Beispielsweise angesichts der folgenden Eingabe:

{
  "batchSize": 131072
}

Sie können die maximale Batchgröße mithilfe eines Referenzpfads wie folgt angeben:

{
  ...
  "Map": {
    "Type": "Map",
    "MaxConcurrency": 2000,
    "ItemBatcher": {
      "MaxInputBytesPerBatchPath": "$.batchSize"
    }
    ...
    ...
  }
}

Optional können Sie auch eine feste JSON Eingabe angeben, die in jeden Batch aufgenommen werden soll, der an jede untergeordnete Workflow-Ausführung übergeben wird. Step Functions führt diese Eingabe mit der Eingabe für jede einzelne untergeordnete Workflow-Ausführung zusammen. Nehmen wir zum Beispiel die folgende feste Eingabe eines Datums der Faktenprüfung für eine Reihe von Elementen an:

"ItemBatcher": {
    "BatchInput": {
        "factCheck": "December 2022"
    }
}

Jede untergeordnete Workflow-Ausführung erhält Folgendes als Eingabe:

{
  "BatchInput": {
    "factCheck": "December 2022"
  },
  "Items": [
    {
      "verdict": "true",
      "statement_date": "6/11/2008",
      "statement_source": "speech"
    },
    {
      "verdict": "false",
      "statement_date": "6/7/2022",
      "statement_source": "television"
    },
    ...
  ]
}