PHP と Google Cloud Tasks を使用した非同期タスクとスケジュール設定

オンライン アプリケーションであっても、オフライン処理タスクであっても、さまざまなタスクを処理する Web アプリケーションにとって、非同期タスクの処理とスケジューリングは非常に重要です。タスクをより適切に管理し、Web アプリケーションのスケーラビリティを維持し、アプリケーションのパフォーマンスを向上させるには、非同期のタスク処理とスケジューリングに依存する必要があります。

Google Cloud Tasks は、API 呼び出しを通じて定期的および非同期タスクを簡単に実行できるフルマネージド サービスです。この記事では、PHP と Google Cloud Tasks を使用して非同期タスクとスケジュールを実装する方法を説明します。 Google Cloud Tasks の設定方法とタスクキューの使用方法を学びます。

始める前に、サービスを使用するために Google Cloud SDK をインストールし、Google Cloud Tasks を設定し、Google Cloud プロジェクトを作成する必要があります。

Google Cloud SDK のインストール

Google Cloud SDK は、クラウド リソースの管理と実行に一般的に使用されるコマンドライン ツールです。次のコマンドを使用して Google Cloud SDK をインストールできます:

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

インストール プロセス中、画面上のプロンプトに従って Google アカウント情報を入力する必要があります。

Google Cloud タスクのセットアップ

次に、Google Cloud タスクをセットアップする必要があります。 Cloud Tasks では、タスクはタスク キュー、タスク、エグゼキュータという 3 つの主要な要素で構成されます。

タスク キューは、新しいタスクを配置できるようにする特定の名前を持つリソースです。タスクキュー名はグローバルに一意です。

タスクは、作成してタスク キューに追加する説明的なオブジェクトです。

エグゼキューターは、タスクの実行時に呼び出される実際のコードであり、通常は Web アプリケーション内にあります。

このチュートリアルでは、次の値を使用します:

• プロジェクト ID: my-project-id
• タスク キュー ID: my-queue
• クラウド関数 URL: https://us-central1-my-project-id.cloudfunctions.net/processTask

それでは、クラウド タスクを簡単に設定してみましょう。

1. まず、Cloud Tasks のタスク API を有効にする必要があります。 Cloud Console で、Cloud Tasks を構成するプロジェクトを選択し、[API とサービス] > [ライブラリ] に移動します。検索ボックスに「Cloud Tasks API」と入力し、[Cloud Tasks API] をクリックして有効にします。
2. 次に、タスクキューを作成する必要があります。次の gcloud コマンドを使用できます:

gcloud tasks queues create my-queue

このコマンドは、my-queue という名前のタスク キューを作成します。 App Engine や Cloud Functions などの他のサービスを使用する場合は、それらのサービスをこのキューにバインドして、タスクの処理を容易にすることができます。

3. 実行プログラムを作成します。このチュートリアルでは、Cloud Functions をエグゼキュータとして使用します。したがって、クラウド機能を作成する必要があります。

Cloud コンソールで、Cloud Functions を構成するプロジェクトを選択し、Cloud Functions に移動します。 「関数の作成」をクリックし、新しい関数の名前「processTask」を入力します。

次の Cloud 関数コードを使用します:

<?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.');
}

この関数には Google Cloud Storage へのアクセスが必要なので、アクセスを許可する必要もあります。 Cloud Console で、[ストレージ] > [参照] に移動します。次に、「バケットの作成」をクリックし、新しいバケットの標準ストレージを選択し、「my-bucket」という名前を入力します。

バケット タブで、[権限] をクリックします。 [エンティティの追加] を選択して、プログラム「cloud-tasks@cloudtasks.googleapis.com」権限をサービスに追加します。 [ロールの選択] の [ロール] ドロップダウン リストで、[クラウド タスク タスク実行者] を選択します。

これで、Cloud Function でタスク共有コードを使用する準備が整いました。

4. タスクを作成します。これで、タスク キューのタスクを作成できるようになりました。次の gcloud コマンドを使用します。

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"}'

上記の gcloud コマンドを使用して、「message」属性を「hello world」に設定した JSON 形式の POST リクエストを作成します。このタスクは my-queue キューに追加されます。

これで、クラウド タスクを取得するための完全なセットアップが完了しました。

PHP を使用したクラウド タスクの読み込み

クラウド タスクの設定が完了したので、PHP を使用してクラウド タスクを読み込みましょう。 Google は、google/cloud-tasks という公式の PHP パッケージを提供しています。 Composer を使用してインストールできます。

composer require google/cloud-tasks

これで、PHP コードを記述してタスクを作成し、タスク キューに追加できます。次の例を見てみましょう:

<?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();

このコードは、「my-queue」という名前のタスク キューを作成します。次に、タスクを作成してキューに追加します。タスクには、URL、HTTP メソッド、および POST リクエストのデータ本体が含まれます。

タスクには、10 秒後にタスクが実行されるようにスケジュールされた時間も含まれています。

最後に、「createTask」メソッドを使用してタスクをキューに追加します。

概要

この記事では、PHP と Google Cloud Tasks を使用してタスクのスケジュール設定と非同期タスク処理を実装する方法を説明します。 Cloud Tasks は、定期的および非同期タスクを実行する API を簡単に呼び出すことができるフルマネージド サービスです。 PHP を使用して、クラウド関数を設定し、タスク キューを作成し、キューにタスクを追加しました。

実際のアプリケーションでは、より複雑な機能やサービスが追加される可能性があり、必要に応じてさらに多くのキューやタスクを追加できます。ただし、これは、Google Cloud Tasks をウェブ アプリケーションに統合するための良い出発点となります。

以上がPHP と Google Cloud Tasks を使用した非同期タスクとスケジュール設定の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。