将Firebase与第三方API集成

Question

我想将我的firebase项目与一些第三方API集成，比如twitter API。

第三方API

以下代码将收听包含特定文本“小火箭人”的新推文：

var Twitter = require('twitter');

// setup new twitter client
var client = new Twitter({
  consumer_key: '',
  consumer_secret: '',
  access_token_key: '',
  access_token_secret: ''
});

// open new twitter stream
let stream = this.client.stream('statuses/filter', { track: 'little rocket man' });

stream.on('data', (event: any) => {
  let tweetText = event && event.text; // this should be written to the firebase db
});

Firebase云函数

以下Firebase云函数侦听特定路由上传入的HTTP GET请求，并将数据保存回Firebase数据库：

import * as functions from 'firebase-functions';
import * as admin from 'firebase-admin'; // Firebase Admin SDK

admin.initializeApp(functions.config().firebase);

// this example uses a HTTP trigger, but how can I trigger it whenever new tweets containint 'little rocket man' are detected??
exports.addMessage = functions.https.onRequest((req, res) => {
  const original = req.query.text;

  admin.database().ref('/messages').push({original: original}).then(snapshot => {
    res.redirect(303, snapshot.ref);
  });
});

问题

如何将从twitter客户端收到的推文写回firebase db？如果可能，我想在firebase云函数上运行所有代码。

免责声明：我是Firebase的新手，尽管我在网上搜索了几个小时，但还是没能找到解决问题的方法。我想提前道歉，如果我监督的话。

Answer 1

在云函数中不能使用这样的流式API。函数可能只响应某些不同的事件，例如HTTP请求或数据库中的某些更改。函数不能无限期运行。

如果您想将匹配某个查询的tweet收集到数据库中，可以使用IFTTT定期将其发送到可用的函数。我最近完成了一个小项目，就是这样做的。