Asynchrone Aufgaben und Planung mit PHP und Google Cloud Tasks

Ob es sich um eine Online-Anwendung oder eine Offline-Verarbeitung von Aufgaben handelt, die asynchrone Aufgabenverarbeitung und -planung ist für Webanwendungen, die verschiedene Aufgaben verarbeiten, sehr wichtig. Um Aufgaben besser zu verwalten, Webanwendungen skalierbar zu halten und die Anwendungsleistung zu verbessern, müssen wir uns auf die asynchrone Aufgabenverarbeitung und -planung verlassen.

Google Cloud Tasks ist ein vollständig verwalteter Dienst, der die einfache Ausführung periodischer und asynchroner Aufgaben über API-Aufrufe erleichtert. In diesem Artikel erfahren Sie, wie Sie asynchrone Aufgaben und Planung mit PHP und Google Cloud Tasks implementieren. Wir erfahren, wie Sie Google Cloud Tasks einrichten und Aufgabenwarteschlangen verwenden.

Bevor wir beginnen, müssen wir das Google Cloud SDK installieren, Google Cloud Tasks einrichten und ein Google Cloud-Projekt erstellen, um den Dienst nutzen zu können.

Google Cloud SDK installieren

Google Cloud SDK ist ein Befehlszeilentool, das häufig zum Verwalten und Ausführen von Cloud-Ressourcen verwendet wird. Sie können das Google Cloud SDK mit dem folgenden Befehl installieren:

curl https://sdk.cloud.google.com | bash

Während des Installationsvorgangs müssen Sie den Anweisungen auf dem Bildschirm folgen und Ihre Google-Kontoinformationen eingeben.

Google Cloud Tasks einrichten

Als nächstes müssen wir Google Cloud Tasks einrichten. In Cloud Tasks besteht eine Aufgabe aus drei Schlüsselelementen: Aufgabenwarteschlange, Aufgabe und Ausführer.

Eine Aufgabenwarteschlange ist eine Ressource mit einem bestimmten Namen, die es Ihnen ermöglicht, neue Aufgaben zu platzieren. Namen von Aufgabenwarteschlangen sind weltweit eindeutig.

Aufgaben sind beschreibende Objekte, die Sie erstellen und einer Aufgabenwarteschlange hinzufügen.

Der Executor ist der eigentliche Code, der beim Ausführen der Aufgabe aufgerufen wird und sich normalerweise in Ihrer Webanwendung befindet.

In diesem Tutorial verwenden wir die folgenden Werte:

• Projekt-ID: my-project-id
• Aufgabenwarteschlangen-ID: my-queue
• Cloud-Funktions-URL: https://us-central1-my-project - id.cloudfunctions.net/processTask

Jetzt richten wir schnell Cloud Tasks ein.

1. Zuerst müssen wir die Aufgaben-API für Cloud Tasks aktivieren. Wählen Sie in der Cloud Console das Projekt aus, aus dem Sie Cloud Tasks konfigurieren möchten, und gehen Sie zu APIs & Services > Bibliotheken. Geben Sie „Cloud Tasks API“ in das Suchfeld ein und klicken Sie auf Cloud Tasks API, um es zu aktivieren.
2. Als nächstes müssen wir die Aufgabenwarteschlange erstellen. Wir können den folgenden gcloud-Befehl verwenden:

gcloud tasks queues create my-queue

Dieser Befehl erstellt eine Aufgabenwarteschlange mit dem Namen my-queue. Wenn Sie andere Dienste wie App Engine oder Cloud Functions verwenden, können Sie diese an diese Warteschlange binden, um die Verarbeitung von Aufgaben zu erleichtern.

3. Erstellen Sie einen Testamentsvollstrecker. In diesem Tutorial verwenden wir Cloud Functions als Executor. Daher müssen wir eine Cloud-Funktion erstellen.

Wählen Sie in der Cloud Console das Projekt aus, aus dem Sie Cloud Functions konfigurieren möchten, und gehen Sie zu Cloud Functions. Klicken Sie auf Funktion erstellen und geben Sie den Namen „processTask“ für die neue Funktion ein.

Wir werden den folgenden Cloud-Funktionscode verwenden:

<?php

use GoogleCloudStorageStorageClient;
use GoogleCloudLoggingLoggingClient;

function processTask($data, $context)
{
    $bucket = 'my-bucket';

    $logging = new LoggingClient(['projectId' => 'my-project-id']);
    $logger = $logging->psrLogger('my-logger');

    $logger->info('Starting task', ['data' => $data]);

    $storage = new StorageClient(['projectId' => 'my-project-id']);
    $bucket = $storage->bucket('my-bucket');

    // TODO: Process the task

    $logger->info('Task completed successfully.');
}

Diese Funktion erfordert Zugriff auf Google Cloud Storage, daher müssen wir ihr auch Zugriff gewähren. Gehen Sie in der Cloud Console zu Speicher > Durchsuchen. Klicken Sie anschließend auf „Bucket erstellen“, wählen Sie den Standardspeicher für den neuen Bucket aus und geben Sie den Namen „my-bucket“ ein.

Klicken Sie im Bucket-Tab auf „Berechtigungen“. Wählen Sie „Entität hinzufügen“, um dem Dienst die Programmberechtigung „cloud-tasks@cloudtasks.googleapis.com“ hinzuzufügen. Wählen Sie unter „Rolle auswählen“ in der Dropdown-Liste „Rolle“ die Option „Cloud Tasks Task Performer“ aus.

Jetzt ist die Cloud-Funktion bereit, den Aufgabenteilungscode zu verwenden.

4. Aufgaben erstellen. Wir können jetzt Aufgaben für die Aufgabenwarteschlange erstellen. Wir verwenden den folgenden gcloud-Befehl:

gcloud tasks create-http-task 
    --queue=my-queue 
    --url=https://us-central1-my-project-id.cloudfunctions.net/processTask 
    --http-method=POST 
    --body='{"message":"hello world"}'

Mit dem obigen gcloud-Befehl erstellen wir eine POST-Anfrage im JSON-Format, wobei das Attribut „message“ auf „hello world“ gesetzt ist. Diese Aufgabe wird zur My-Queue-Warteschlange hinzugefügt.

Das ist alles für die vollständige Einrichtung von Cloud Tasks.

Cloud Tasks mit PHP laden

Da wir nun die Einstellungen für Cloud Tasks haben, laden wir Cloud Tasks mit PHP. Google stellt ein offizielles PHP-Paket namens google/cloud-tasks zur Verfügung. Sie können es mit Composer installieren:

composer require google/cloud-tasks

Jetzt können wir den PHP-Code schreiben, um die Aufgabe zu erstellen und sie zur Aufgabenwarteschlange hinzuzufügen. Schauen wir uns das folgende Beispiel an:

<?php

require_once __DIR__ . '/vendor/autoload.php';

use GoogleCloudTasksV2CloudTasksClient;
use GoogleCloudTasksV2HttpMethod;
use GoogleCloudTasksV2Queue;
use GoogleCloudTasksV2Task;
use GoogleProtobufDuration;

$projectId = 'my-project-id';
$location = 'us-central1';
$queueId = 'my-queue';

$cloudTasksClient = new CloudTasksClient();

$queueName = $cloudTasksClient->queueName($projectId, $location, $queueId);
$queue = new Queue();
$queue->setName($queueName);

$taskName = $cloudTasksClient->taskName($projectId, $location, $queueId, uniqid());
$task = new Task();
$task->setName($taskName);

$taskHttpReq = new GoogleCloudTasksV2HttpRequest();
$taskHttpReq->setUrl('https://us-central1-my-project-id.cloudfunctions.net/processTask');
$taskHttpReq->setHttpMethod(HttpMethod::POST);

$taskHttpReq->setBody(json_encode(['message' => 'hello world']));
$task->setHttpRequest($taskHttpReq);

$delay = new Duration();
$delay->setSeconds(10);
$task->setScheduleTime($delay);

$cloudTasksClient->createTask($queue, $task);

$cloudTasksClient->close();

Dieser Code erstellt eine Aufgabenwarteschlange namens „my-queue“. Als nächstes erstellt es eine Aufgabe und fügt sie der Warteschlange hinzu. Die Aufgabe enthält die URL, die HTTP-Methode und den Datenkörper der POST-Anfrage.

Die Aufgabe enthält auch eine geplante Zeit, sodass die Aufgabe nach 10 Sekunden ausgeführt wird.

Abschließend verwenden wir die Methode „createTask“, um die Aufgabe zur Warteschlange hinzuzufügen.

Zusammenfassung

Dieser Artikel zeigt Ihnen, wie Sie die Aufgabenplanung und die asynchrone Aufgabenverarbeitung mit PHP und Google Cloud Tasks implementieren. Cloud Tasks ist ein vollständig verwalteter Dienst, der den einfachen Aufruf von APIs ermöglicht, die periodische und asynchrone Aufgaben ausführen. Wir haben eine Cloud-Funktion eingerichtet, eine Aufgabenwarteschlange erstellt und mithilfe von PHP Aufgaben zur Warteschlange hinzugefügt.

In einer realen Anwendung können komplexere Funktionen und Dienste hinzugefügt werden, und bei Bedarf können weitere Warteschlangen und Aufgaben hinzugefügt werden. Dies sollte Ihnen jedoch einen guten Ausgangspunkt für die Integration von Google Cloud Tasks in Ihre Webanwendung bieten.

Das obige ist der detaillierte Inhalt vonAsynchrone Aufgaben und Planung mit PHP und Google Cloud Tasks. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!