Cloud Tasks – Übersicht

Auf dieser Seite werden Cloud Tasks-Aufgaben und -Warteschlangen sowie deren Verwendung beschrieben. Mit Cloud Tasks können Sie Aufgaben, die unabhängig vom Hauptanwendungsablauf ausgeführt werden können, trennen und asynchron mit von Ihnen erstellten Handlern zur Verarbeitung senden. Diese unabhängigen Aufgaben werden als Aufgaben bezeichnet. Beispielsweise müssen Sie eine Datenbank im Rahmen der Verarbeitung einer Nutzeranfrage aktualisieren, aber Aktualisierungen können zeitaufwendig sein. Wenn Sie dieses Detail als Aufgabe auslagern, können Sie schneller von der Anfrage zurückkehren.

Die ausgelagerte Aufgabe wird einer Warteschlange hinzugefügt, die die Aufgabe so lange aufbewahrt, bis sie erfolgreich ausgeführt wurde. Die Warteschlange kann auch als eine Art Steuerung des Weiterleitungsablaufs dienen, die auf Ihrer Anfangskonfiguration basiert. Sie erstellen und konfigurieren die Warteschlange, die dann vom Cloud Tasks-Dienst verwaltet wird. Sobald Aufgaben hinzugefügt wurden, werden sie von der Warteschlange weitergeleitet und von den Mitarbeitern zuverlässig verarbeitet. Die mit diesem Prozess verbundenen Kosten, wie z. B. Kosten für die Latenz des Nutzers, Serverabstürze, Beschränkungen des Ressourcenverbrauchs und die Verwaltung von Wiederholungen, werden vom Dienst verarbeitet.

Die Aufgaben selbst bestehen aus einem eindeutigen Namen und Konfigurationsinformationen sowie optional aus Daten der ursprünglichen Anfrage. Diese Informationen werden als Nutzlast bezeichnet, die zur Verarbeitung der Anfrage erforderlich ist. Da die Nutzlast im Anfragetext gesendet wird, müssen Aufgaben, die Nutzlasten enthalten, POST oder PUT als HTTP-Methode verwenden.

Nutzer von Laufzeiten der ersten Generation der App Engine-Standardumgebung sollten über die App Engine Task Queue API auf den Cloud Tasks-Dienst zugreifen. Weitere Informationen zur Verwendung dieser Methode finden Sie in der Dokumentation zu Java 8, Python 2.7, Go 1.9 oder PHP 5.5. Nutzer von Laufzeiten der zweiten Generation der App Engine-Standardumgebung, Nutzer der flexiblen App Engine-Umgebung und Nutzer anderer Plattformen können jetzt die Cloud Tasks API verwenden.

Für den Zugriff auf den Cloud Tasks-Dienst mit der Cloud Tasks API benötigen Sie ein Projekt mit einer App Engine-Anwendung, die die von Ihnen erstellten Cloud Tasks-Warteschlangen hostet. Diese Anwendung befindet sich in einer bestimmten Region, die als LOCATION_ID-Parameter für Ihre Cloud Tasks-Anfragen dient. Achten Sie also darauf, dass Sie sich die Region notieren. Die Anwendung dient als Speicherort für alle vom Entwickler erstellten Warteschlangen. Auch der zugrunde liegende Cloud Tasks-Dienst wird an diesem Speicherort ausgeführt.

Anwendungsfälle

Zu den typischen Anwendungsfällen gehören:

  • Beschleunigung von Nutzerreaktionszeiten durch Delegieren potenziell langsamer Hintergrundvorgänge wie Datenbankaktualisierungen an einen Worker
  • Beibehaltung von Anfragen bei unerwarteten Vorfällen im laufenden Betrieb
  • Ausgleich von Trafficspitzen durch Entfernen nicht nutzerbezogener Aufgaben aus der Hauptaufrufabfolge von Webseiten
  • API-Aufrufraten von Drittanbietern verwalten

Cloud Tasks-Warteschlangen mit HTTP-Zielen

Bei allgemeinen HTTP-Zielen leitet der Cloud Tasks-Dienst die Aufgabenanfrage an den Worker weiter. Dieser befindet sich an einem beliebigen HTTP-Endpunkt, beispielsweise Cloud Functions, Cloud Run, GKE, Compute Engine oder sogar an einem lokalen Webserver, je nachdem, wie die Aufgabe konfiguriert ist. Diese Warteschlangen leiten Anfragen mit einer zuverlässigen, konfigurierbaren Rate weiter. Sie garantieren eine zuverlässige Aufgabenausführung: bei Erfolg müssen alle Worker innerhalb von 10 Minuten einen HTTP-Antwortcode (200-299) an den Cloud Tasks-Dienst senden. Wird eine andere Antwort oder keine Antwort gesendet, wird die Aufgabe wiederholt.

HTTP-basierte Warteschlangen

Das Ziel muss das Skalieren von Workern und das Bereinigen von Aufgaben verwalten, sobald diese abgeschlossen sind.

Wenn für Ihr Ziel eine Authentifizierung erforderlich ist, müssen Sie zwei Dienstkonten einrichten, eines für Ihre Anwendung, den Client, und eines für die Warteschlange selbst. Beide Konten müssen die erforderlichen Berechtigungen haben. Außerdem muss eine Kennzeichnung für das Client-Dienstkonto in der Aufgabenanfrage enthalten sein. Weitere Informationen finden Sie unter HTTP-Ziel-Aufgaben erstellen.

Cloud Tasks-Warteschlangen mit App Engine-Zielen

Bei App Engine-Zielen leitet der Cloud Tasks-Dienst die Aufgabenanfrage auch an den Worker innerhalb von App Engine weiter, je nachdem, wie die Aufgabe (bzw. die Warteschlange selbst) konfiguriert ist. Diese Warteschlangen leiten Anfragen mit einer zuverlässigen, konfigurierbaren Rate weiter. Sie garantieren eine zuverlässige Aufgabenausführung. Nach erfolgreicher Ausführung müssen alle Worker einen HTTP-Antwortcode 200-299 an den Cloud Tasks-Dienst senden, in diesem Fall innerhalb einer Frist, die auf dem Typ der Instanzskalierung basiert: 10 Minuten für die automatische Skalierung und bis zu 24 Stunden für die manuelle Skalierung. Wird eine andere Antwort oder keine Antwort gesendet, wird die Aufgabe wiederholt.

App Engine-basierte Warteschlangen

Da die Handler Teil von App Engine sind, kann der Cloud Tasks-Dienst selbst einen Großteil der Prozessverwaltung für die Aufgabe übernehmen, z. B. das Skalieren der Worker entsprechend dem Traffic und das Löschen von Aufgaben nach deren Ausführung.

Workflows

Dies ist der allgemeine Workflow:

  1. Sie erstellen einen Worker, um die Aufgaben zu bearbeiten.
  2. Sie erstellen eine Warteschlange.
  3. Sie erstellen programmgesteuert Aufgaben und fügen sie zur Warteschlange hinzu.
  4. Der Cloud Tasks-Dienst gibt eine Bestätigung an die ursprüngliche Anwendung zurück. Diese signalisiert, dass die Aufgabe erfolgreich in den Cloud Task-Speicher geschrieben wurde. Damit ist die Anfrage zur Aufgabenerstellung hochverfügbar und langlebig.
  5. Die Aufgabe wird an den Worker übergeben.
  6. Der Worker verarbeitet die Aufgabe.
  7. Zum Abschließen der Sequenz gibt der Worker den Erfolgsstatuscode 2xx an den Cloud Tasks-Dienst zurück.

Sobald die Aufgabe an die Warteschlange übergeben wurde, werden der ursprünglichen Anfrage keine Daten mehr zur Verfügung gestellt.

Produkte

Mit Cloud Tasks können Sie asynchrone Arbeitsaufgaben mit den folgenden Steuerelementen weiterleiten:

  • Bestimmte Lieferzeiten planen
  • Zustellungsraten verwalten
  • Wiederholungsprozess konfigurieren
  • Auf einzelne Aufgaben in einer Warteschlange zugreifen und verwalten
  • Deduplizierung von Aufgaben aktivieren

Nutzungsbedingungen

Die folgende Tabelle enthält wichtige Begriffe zur Beschreibung bestimmter Aspekte von Cloud Tasks.

Begriff Definition
Warteschlange Eine Reihe von Aufgaben mit demselben Zieltyp, die von einer einzelnen Konfiguration verwaltet werden.
Zieltyp Festlegung, wo und wie eine Aufgabe verarbeitet wird.
Worker Ein Dienst, der Aufgaben verarbeitet.
Versuch Ein Versuch, eine Aufgabe auszuführen.
Weiterleitung Der Zeitpunkt, an dem eine Aufgabe von Cloud Tasks an ihr Ziel gesendet wurde.
Antwort Eine Antwort von einem Worker, die angibt, ob die Aufgabe erfolgreich abgeschlossen wurde oder fehlgeschlagen ist.
retry Mehrere Versuche, eine Aufgabe auszuführen. Die Anzahl der Wiederholungen wird über die Wiederholungskonfiguration festgelegt.
Ratenbegrenzungen Die Ratenbegrenzungen für eine Warteschlange.

Messwerte

Die folgenden vordefinierten Cloud Tasks-Messwerte sind über Stackdriver verfügbar.

Metriktyp
Anzeigename
Art, Typ, Einheit
Beschreibung
Labels
api/request_count
API-Anfragen
DELTA, INT64, 1
Anzahl der Cloud Tasks API-Aufrufe
api_method: Die aufgerufene API-Methode (z. B. CreateTask).
response_code: Kanonischer Antwortcode als String (z. B. "ok").
queue/depth
BETA-Warteschlangentiefe
GAUGE, INT64, 1
Anzahl der Aufgaben in der Warteschlange Alle 60 Sekunden wird eine Stichprobe erstellt. Nach dem Abruf werden bis zu 120 Sekunden keine Daten angezeigt.
queue/task_attempt_count
Anzahl der Aufgabenversuche
DELTA, INT64, 1
Anzahl der Aufgabenversuche aufgeschlüsselt nach Antwortcode
response_code: Kanonischer Antwortcode als String (z. B. "ok").
queue/task_attempt_delays
Verzögerungen von Aufgabenversuchen
DELTA, DISTRIBUTION, ms
Verzögerung zwischen dem Zeitpunkt des geplanten Versuchs und des tatsächlichen Versuchs