运行 关于 Python Flask AppEngine 在 GCP 中启动的代码
Run code on Python Flask AppEngine startup in GCP
我需要一个 TCP 客户端来不断地监听消息（并为每条消息发布 pub 子事件）
由于 GCP 中没有 Kafka，我正在尝试使用我的烧瓶服务（运行s 在 GCP 中使用 AppEngine）。
我打算将 app.yaml 设置为：
manual_scaling:
instances: 1
但我不知道如何在 flask 应用程序启动时触发代码。
我已经在 main.py 中尝试了 运行ning 代码，并且还试图操纵其中的 main 函数 - 但它显然不起作用，因为 AppEngine 不起作用运行它。
您知道如何在 Flask 应用程序启动时初始化侦听器吗？
（或者关于我应该如何实现发送 pubsub 事件或插入到 Big Query 的 tcp 客户端的任何其他提议？）
我最终自己实现了 Kafka 连接器并使用了 Kafka。
我需要一个 TCP 客户端来不断地监听消息（并为每条消息发布 pub 子事件）
由于 GCP 中没有 Kafka，我正在尝试使用我的烧瓶服务（运行s 在 GCP 中使用 AppEngine）。
我打算将 app.yaml 设置为：
manual_scaling:
instances: 1
但我不知道如何在 flask 应用程序启动时触发代码。
我已经在 main.py 中尝试了 运行ning 代码，并且还试图操纵其中的 main 函数 - 但它显然不起作用，因为 AppEngine 不起作用运行它。
您知道如何在 Flask 应用程序启动时初始化侦听器吗？
（或者关于我应该如何实现发送 pubsub 事件或插入到 Big Query 的 tcp 客户端的任何其他提议？）
我最终自己实现了 Kafka 连接器并使用了 Kafka。