使用 Node.js 的 Google Cloud Storage 更改通知

Question

我有 Firebase 存储桶，我想使用 Node.js Google-cloud 通知 API 来监听存储的变化。

到目前为止我所拥有的：

const gcloud = require('google-cloud');

const storage = gcloud.storage({
  projectId: 'projectId',
  credentials: serviceAccount
});  

const storageBucket = storage.bucket('bucketId');

现在据我了解，我必须创建一个频道才能收听存储更改。

所以我有：

const storageBucketNotificationChannel = storage.channel('channelId', 'resourceId');

这是文档不再清晰的阈值，因为我无法弄清楚 channelId 一个 resourceId 代表什么。

我也不明白如何声明监听频道变化本身。是否有任何生命周期类型的方法可以这样做？

我可以这样做吗？

storageBucketNotificationChannel.onMessage(message => { ... })

Answer 1

根据现有的documentation of the Google Cloud Node.js Client和this Github issue的反馈，节点客户端目前无法创建频道或订阅对象更改通知。

其中一个原因是使用客户端的机器不一定是运行应用程序的机器，因此存在安全风险。但是，仍然可以订阅给定存储桶的对象更改通知，并让通知收到 Node.js GAE 应用程序。

使用对象：watchAll JSON API

使用gsutil订阅时，gsutil sends a POST request to https://www.googleapis.com/storage/v1/b/bucket/o/watch 其中bucket是要监视的bucket的名称。这本质上是JSON API Objects: watchAll 的包装。一旦所需的应用程序/端点如Notification Authorization 中所述被授权，就可以向所述API 发送适当的POST 请求，并在address 中提供所需的端点URL。例如，address 可以是 https://my-node-app.example.com/change。

然后，Node/Express 应用程序服务需要侦听路径 /change 的 POST 请求以获取 notifications resembling this。然后应用程序将相应地对该数据采取行动。请注意，应用程序应响应Reliable Delivery 中所述的请求，以便云存储在失败时重试或在成功时停止重试。