將提取佇列遷移至 Pub/Sub (Java)

本頁說明如何將提取佇列程式碼從工作佇列遷移至 Pub/Sub。在 App Engine 中執行提取佇列工作時,建議使用 Pub/Sub。

如果您的應用程式同時使用提取佇列和推送佇列,請先按照本指南將提取佇列遷移至 Pub/Sub,再將推送佇列遷移至新的推送佇列服務 Cloud Tasks。不建議在將發送佇列遷移至 Cloud Tasks 後,再遷移提取佇列,因為必須使用 queue.yaml 檔案可能會導致 Cloud Tasks 出現非預期的行為。

Pub/Sub 目前無法使用的功能

下列工作佇列功能目前無法在 Pub/Sub 中使用:

  • 依標記批次處理
  • 自動去重

定價與配額

將提取佇列遷移至 Pub/Sub 可能會影響應用程式的價格和配額。

定價

Pub/Sub 有專屬的定價方案。與工作佇列一樣,使用 Pub/Sub 將要求傳送至 App Engine 應用程式,可能會導致應用程式產生費用。

配額

Pub/Sub 配額與工作佇列的配額不同。與工作佇列一樣,從 Pub/Sub 將要求傳送至 App Engine 應用程式,可能會影響 App Engine 要求配額

遷移前

以下各節將說明將拉取佇列遷移至 Pub/Sub 之前的設定步驟。

啟用 Pub/Sub API

如要啟用 Pub/Sub API,請在 API 程式庫中,按一下 Pub/Sub API 上的「啟用」。如果您看到「管理」按鈕,而非「啟用」按鈕,表示您先前已為專案啟用 Pub/Sub API,因此不必再執行這項操作。

讓應用程式通過 Pub/Sub API 驗證

您必須向 Pub/Sub API 驗證應用程式。本節將討論兩種不同用途的驗證方式。

如要在本機開發或測試應用程式,建議您使用服務帳戶。如需設定服務帳戶並將其連結至應用程式的操作說明,請參閱「手動取得及提供服務帳戶憑證」。

如要在 App Engine 上部署應用程式,您不需要提供任何新的驗證機制。應用程式預設憑證 (ADC) 會推斷 App Engine 應用程式的驗證詳細資料。

下載 Google Cloud CLI

如果您先前未安裝 Google Cloud CLI,請下載並安裝該工具,以便搭配 Pub/Sub API 使用 gcloud CLI。如果您已安裝 Google Cloud CLI,請透過終端機執行下列指令。

gcloud components update

匯入 Cloud 用戶端程式庫

請按照 Pub/Sub 操作說明安裝用戶端程式庫,以便在應用程式中使用用戶端程式庫。

Pub/Sub 和提取佇列

功能比較

Pub/Sub 會透過發布端/訂閱端關係將工作傳送至 worker。Pub/Sub 中的提取訂閱項目就像工作佇列中的提取佇列,因為訂閱端會從主題提取訊息。下表列出工作佇列中提取佇列的核心功能,以及 Pub/Sub 中提取訂閱項目的相關功能。

工作佇列功能 Pub/Sub 功能
佇列 主題
工作 訊息
工作站 訂閱端

如要進一步瞭解 Pub/Sub 架構,請參閱「Cloud Pub/Sub:Google 規模的訊息傳遞服務」。

工作流程比較

以下比較工作佇列中提取佇列的典型工作流程,以及 Pub/Sub 中的提取訂閱項目

工作佇列工作流程 Pub/Sub 工作流程
您建立提取佇列 您建立主題,並讓訂閱者 (即 worker) 訂閱該主題
您建立並將工作加入佇列 您建立訊息並將其發布至主題
工作站租用工作 訂閱者從主題中提取訊息
工作站處理工作 訂閱端處理訊息
工作站從佇列中刪除工作 訂閱者確認收到訊息
租約到期 當所有訂閱者都已確認訊息時,主題會刪除訊息

在 Pub/Sub 中建立提取訂閱

您可以使用 Pub/Sub 提取訂閱,就像使用工作佇列提取佇列一樣。主題訂閱不會過期,且可同時存在於多個 worker。也就是說,一則訊息可以由多個 worker 處理,這是 Pub/Sub 的主要用途之一。如要重新建立 Task Queues 拉取佇列做為 Pub/Sub 拉取訂閱,請為每個 worker 建立主題,並只將相關聯的 worker 訂閱至主題。這可確保每則訊息都由一個工作站處理,就像工作佇列一樣。如要瞭解如何建立及管理拉取訂閱,請參閱管理主題和訂閱項目

刪除提取佇列

將工作佇列提取佇列遷移至 Pub/Sub 提取訂閱後,請使用 queue.yaml 檔案從工作佇列中刪除這些佇列。建議您先刪除每個拉取佇列,再遷移下一個佇列。這樣一來,您就能在遷移其他拉取佇列時,避免應用程式重複執行從新的 Pub/Sub 拉取訂閱項目收到的工作。請注意,如果刪除 Task Queues 提取佇列時,不是一次刪除一個,而是在單一部署作業中刪除,可能會對 App Engine 部署配額造成更大的影響。

從工作佇列中刪除所有拉取佇列後,您可以在日後的應用程式部署中省略 queue.yaml 檔案。

如果您的應用程式只使用提取佇列,請在程式碼中移除任何 Task Queues API 參照。如果應用程式同時使用提取佇列和推送佇列,您可以移除只使用提取佇列的檔案中 Task Queues API 的參照,或是等到推送佇列遷移完成後,再從所有檔案中移除 Task Queues API 的參照。

後續步驟