如何为连续的数据流提供连续的 firebase 云功能？

Question

我需要使用 Twitter Stream API 将推文数据流式传输到我的 firebase 云函数，如下所示：

client.stream('statuses/filter', params,  stream => {

  stream.on('data', tweet => {
    console.log(tweet);
  })

  stream.on('error', error => {
    console.log(error)
  })

})

流是连续的，但 firebase 云功能在一段时间后关闭。我可以使用什么方案来持续接收流数据？

Answer 1

Cloud Functions 的最大运行宁时间为 540 秒 as documented. You would have to look at probably using a Compute Engine Instance from Google Cloud where you can have code running without limits. Or you could look at using the Google Cloud Scheduler 到运行您的函数每 x 次获取新推文。

Answer 2

接受的回复建议运行 GCE，虽然它肯定是正确的，但我想指出任何对 Cloud Functions（一种无服务器解决方案）感兴趣的人可能会发现 GAE（App Engine）更多可行的流数据。

我们的应用程序使用 App Engine Standard 作为摄取服务，它的工作原理非常棒 - 消除了 GCE 所需的开销。如果您的应用需要高级网络功能，App Engine Flexible 或 GKE（Kubernetes 引擎）也可能值得关注！

如何为连续的数据流提供连续的 firebase 云功能？

How can I have a continuous firebase cloud function for a continuous stream of data?

twitter

firebase

twitter-streaming-api

google-cloud-functions