AI 摘要
- Google Spanner 新增原生訊息佇列功能，可在同一筆交易中同步處理資料更新與任務派送。
- 功能支援 SQL 操作、任務延遲排程與至少送達一次的傳遞保證。
- 新功能目前提供給 Google Spanner Enterprise 及 Enterprise Plus 版本使用。
Google 宣布為其分散式資料庫 Google Spanner 推出全新的原生訊息佇列（Message Queue）功能。這項新功能讓開發人員與 AI 應用程式能夠在同一筆資料庫交易中，同步處理資料狀態更新並將後續任務寫入佇列，確保兩個動作同時成功或同時取消，有效避免 AI 代理在執行業務邏輯時出現資料與工作狀態不一致的狀況。
解決 AI 代理與分散式系統狀態不同步痛點
在現行的 AI 代理應用場景中，例如處理退款、調整庫存或委派多代理任務時，系統往往需要修改資料庫並將工作發送至外部訊息佇列。若由不同系統分開處理，容易發生資料已變更但任務遺失，或是任務已發出但資料庫交易失敗的問題。Google Spanner 透過將訊息佇列直接整合至資料庫內部，讓狀態更新與任務派送能綁定在同一個交易中，只有在交易完全提交時才會生效。
支援 SQL 操作與靈活任務排程
Google Spanner 原生訊息佇列提供多項彈性的任務管理機制：
- SQL 介面存取：後端工作程式可直接使用標準 SQL 語法從佇列中獲取任務，並在完成後更新狀態與移除訊息。
- 延遲排程執行：支援指定任務在特定時間後啟動，適用於逾時自動升級或待審核流程。
- 延長鎖定時間：針對 AI 代理呼叫外部服務或執行多步驟任務等耗時操作，處理端可動態延長任務持有時間。
訊息傳遞可靠性與版本支援
在傳遞可靠性方面，Google Spanner 確保訊息「至少送達一次（At-least-once delivery）」，單一訊息最多僅會被確認成功一次。面對網路異常或執行失敗時，任務可能會重新派送，因此針對付款等不可重複操作的任務，應用層仍需具備冪等性（Idempotency）設計。
此項原生訊息佇列功能主要面向交易完成觸發與延遲任務管理，目前已正式開放給 Google Spanner Enterprise 以及 Enterprise Plus 版本的用戶使用。
Spanner 原生訊息佇列與變更串流差異比較
| 比較項目 | 原生訊息佇列 (Message Queue) | 變更串流 (Change Streams) |
|---|---|---|
| 主要用途 | 交易完成後觸發後續工作、排程延遲任務、逐項確認完成狀態 | 持續擷取資料異動事件，供下游系統處理 |
| 資料處理方式 | 支援透過 SQL 主動拉取、處理與確認完成後移除 | 串流式被動接收資料變更歷程 |
| 適用情境 | AI 代理任務指派、訂單與退款流程處理 | 下游分析、資料倉儲同步、長期資料儲存 |
| 支援版本 | Enterprise、Enterprise Plus | Spanner 各支援版本 |
Reference Link : ithome.com.tw
