So skalieren Sie Mitarbeiter automatisch in AWS-Schrittfunktionen

Question

Wir implementieren einen Prozess mit AWS-Schrittfunktionen. Einige der Aufgaben in diesem Prozess benötigen viel Zeit. Wir verwenden für diesen Schritt Aktivitäten (Worker), die in ECS-Instanzen ausgeführt werden. Die Zustandsmaschine ist wie folgt aus:

Auslöser -> Schritt 1 (Lambda) -> Schritt 2 (ECS) -> letzter Schritt

Gibt es eine Möglichkeit, die Anzahl der Aufgaben in der Warteschlange zu finden von den Step2-Mitarbeitern abgeholt werden und diese Informationen verwenden, um die Arbeiter automatisch zu skalieren (ECS-Cluster)?

Answer 1

Sie können die API-Aufruf list_executions die Liste der Lauf Hinrichtung und als für jede dieser Ausführungen nennt get_execution_history zu bekommen.

In der Antwort können Sie die Ausführungsereignisse iterieren. Wenn Sie in der Liste ActivityScheduled finden und Sie ActivityStarted nicht sehen, bedeutet es, dass es auf einen Arbeiter wartet, um diese Aufgabe zu übernehmen.