我需要一個 TCP 客戶端來不斷地監聽訊息(并為每條訊息發布發布子事件)
由于 GCP 中沒有 Kafka,我正在嘗試使用我的 Flask 服務(在 GCP 中使用 AppEngine 運行)來實作。
我打算將其設定app.yaml為:
manual_scaling:
instances: 1
但我不知道如何在 Flask 應用程式啟動時觸發代碼。
我試過在 中運行代碼main.py并嘗試操作其中的main函式 - 但它顯然不起作用,因為 AppEngine 不運行它。
您知道如何在 Flask 應用程式啟動時初始化偵聽器嗎?
(或者關于我應該如何實作發送 pubsub 事件或插入 Big Query 的 tcp 客戶端的任何其他提議?)
uj5u.com熱心網友回復:
我最終自己實作了一個 Kafka 連接器并使用了 Kafka。
轉載請註明出處,本文鏈接:https://www.uj5u.com/qukuanlian/395708.html
