無論是線上應用程式還是離線處理任務,對於處理各種任務的網路應用程序,非同步任務處理和調度都是非常重要的。為了更好地管理任務,保持網路應用程式的可擴展性並提高應用程式的效能,我們必須依賴非同步任務處理和調度。
Google Cloud Tasks是一個完全託管的服務,可以輕鬆地透過API呼叫執行定期任務和非同步任務。本文將向您展示如何使用PHP和Google Cloud Tasks實現非同步任務和調度。我們將學習如何設定Google Cloud Tasks以及如何使用任務佇列。
在開始之前,我們需要安裝Google雲端SDK,設定Google Cloud Tasks,並建立一個Google Cloud Project以使用該服務。
安裝Google Cloud SDK
Google雲端SDK是一個命令列工具,通常用於管理和運行雲端資源。您可以使用以下命令來安裝Google雲端SDK:
curl https://sdk.cloud.google.com | bash
在安裝過程中,您需要遵循螢幕上的提示並輸入您的Google帳戶資訊。
設定Google Cloud Tasks
接下來,我們需要設定Google Cloud Tasks。在Cloud Tasks中,任務由3個關鍵要素構成:任務佇列,任務,執行程式。
任務佇列是具有特定名稱的資源,可讓您放置新的任務。任務隊列名稱是全域唯一的。
任務是由您建立並將其新增至任務佇列中的描述性物件。
執行程式是任務執行時期呼叫的實際程式碼,通常位於您的網路應用程式中。
在本教學中,我們將使用以下值:
現在,讓我們快速設定Cloud Tasks。
gcloud tasks queues create my-queue
此指令會建立一個名為my-queue的任務佇列。如果您使用其他服務,例如App Engine或Cloud Functions,則可以將它們綁定到該佇列以便於處理任務。
在Cloud Console中,選擇要從中設定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 Tasks任務執行者」。
現在,Cloud函數已準備好使用任務共享程式碼。
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指令,我們將建立一個POST請求,採用JSON格式,「message」屬性設定為「hello world」。此任務將會被加入到my-queue佇列中。
這就是取得Cloud Tasks的完整設定。
使用PHP載入Cloud Tasks
現在,我們已經為Cloud Tasks進行了設置,讓我們使用PHP載入Cloud Tasks。 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」的任務佇列。接下來,它將建立一個任務,並將其新增到佇列中。任務包含POST請求的URL,HTTP方法和資料體。
任務也包含計畫時間,使任務在10秒後執行。
最後,我們使用「createTask」方法,將任務新增到佇列。
總結
本文向您展示如何使用PHP和Google Cloud Tasks實現任務調度和非同步任務處理。 Cloud Tasks是一個完全託管的服務,可以輕鬆地呼叫執行定期任務和非同步任務的API。我們設定了一個Cloud函數,建立了任務隊列,並使用PHP將任務新增到隊列中。
在實際應用程式中,可能會添加更複雜的功能和服務,並且可以根據需要添加更多的佇列和任務。但是,這應該為您提供將Google Cloud Tasks整合到Web應用程式中的良好起點。
以上是使用PHP和Google Cloud Tasks實現非同步任務和調度的詳細內容。更多資訊請關注PHP中文網其他相關文章!