用于 API 调用的 Google Cloud Functions Cron 作业

Question

我正在尝试设置一个 Firebase 云函数，该函数会定期对 Feedly API 进行 api 调用。

但是，它不起作用，我不确定为什么。代码如下：

const functions = require('firebase-functions')
const express = require('express')
const fetch = require('node-fetch')
const admin = require('firebase-admin')

admin.initializeApp()
const db = admin.firestore()

const app = express()

exports.getNewsArticles = functions.pubsub
  .schedule('every 5 minutes')
  .onRun(() => {
    app.get('/feedly', async (request, response) => {

      const apiUrl = `https://cloud.feedly.com/v3/streams/contents?streamId=user/[USER_ID_NUMBER]/category/global.all&count=100&ranked=newest&newThan=300000`

      const fetchResponse = await fetch(apiUrl, {
        headers: {
          Authorization: `Bearer ${functions.config().feedly.access}`
        }
      })

      const json = await fetchResponse.json()

      json.items.forEach(item => {
        db.collection('news').add({
          status: 'pending',
          author: item.author || '',
          content: item.content || '',
          published: item.published || '',
          summary: item.summary || '',
          title: item.title || '',
        })
      })
    })
  })

知道我需要做什么才能让它工作吗？

Answer 1

您的云函数可能存在三个问题：

1。您正在将调度函数的代码与 HTTPS 函数之一混合

查看Schedule Functions 和HTTPS Functions 的文档。在 Schedule Function 中，您不应该使用 app.get() 而只是这样做，例如：

exports.scheduledFunction = functions.pubsub.schedule('every 5 minutes').onRun((context) => {
  console.log('This will be run every 5 minutes!');
  return null;
});

2。你必须返回一个 Promise（或一个值）

您必须在 Cloud Function 中返回一个 Promise（或一个值），以向平台表明 Cloud Function 已完成。如果 Cloud Function 中的任务是同步的，您可以只返回一个值，例如return null; 如上例所示。如果一个或多个任务是异步的，你必须返回一个 Promise。

因此，在您的情况下，您需要按如下方式使用Promise.all()，因为您正在并行执行多个（异步）写入：

exports.getNewsArticles = functions.pubsub
  .schedule('every 5 minutes')
  .onRun((context) => {

      const apiUrl = `https://cloud.feedly.com/v3/streams/contents?streamId=user/[USER_ID_NUMBER]/category/global.all&count=100&ranked=newest&newThan=300000`

      const fetchResponse = await fetch(apiUrl, {
        headers: {
          Authorization: `Bearer ${functions.config().feedly.access}`
        }
      })

      const json = await fetchResponse.json()

      const promises = [];

      json.items.forEach(item => {
        promises.push(
          db.collection('news').add({
            status: 'pending',
            author: item.author || '',
            content: item.content || '',
            published: item.published || '',
            summary: item.summary || '',
            title: item.title || '',
          }))
      })

      return Promise.all(promises)
  })

3。您可能需要升级定价计划

您需要使用“Flame”或“Blaze”定价计划。

事实上，免费的“Spark”计划“只允许向 Google 拥有的服务发出出站网络请求”。请参阅https://firebase.google.com/pricing/（将鼠标悬停在“云功能”标题后面的问号上）

由于 Feedly API 不是 Google 拥有的服务，您可能需要切换到“Flame”或“Blaze”计划。