如何使用 Azure 函数时间触发器获取所有 blob 存储（新的或更新的）

Question

我有要求，我需要获取在特定持续时间后更新或添加的所有blob存储。

示例：-在容器中，我将zip文件列表作为blob，我需要在给定的时间间隔内获取所有更新或新添加的blob，例如每隔1小时我需要获取所有新添加或更新的blob。

所以我使用了azure函数，其中创建了一次触发函数，但无法获取所有blob（更新或新添加）。

谁能告诉我如何解决这个问题。

作用json文件

"bindings": [
{
  "name": "myTimer",
  "type": "timerTrigger",
  "direction": "in",
  "schedule": "0 */2 * * * *"
},
{
  "type": "blob",
  "name": "myBlob", 
  "path": "*****/******.zip",     
  "connection": "***************",
  "direction": "in"
}

]，“禁用”:false }

索引.js

module.exports = function(context, trigger, inputBlob) {
context.log(inputBlob);
//it's also available on context.bindings
context.log(context.bindings.inputBlob); // will log the same thing as above
context.done();

}

提前致谢。

Answer 1

您的方案是将Azure事件网格（现已在预览版中）解决方案与事件驱动的blob存储发布者一起使用的好选择。此处有更多详细信息。

基本上，对于容器、blob存储或者Azure订阅的数量没有限制。如果您的blob存储已为事件兴趣订阅，例如blob已被创建或删除，则自定义过滤的事件消息可被传递给订阅者，例如EventGridTrigger函数。

以下屏幕片段显示了事件驱动的blob存储的示例:

以下日志显示了当blob已被删除时，函数收到的事件消息:

请注意，可以根据主题和/或 eventType 属性在订阅中筛选 Blob 存储发布者发送的事件消息。换句话说，每个订阅都可以告知事件网格其事件源兴趣。

对于流式处理事件及其分析，可以为事件中心订阅者订阅事件网格，请参阅以下屏幕代码段：

来自源兴趣的所有事件都将引入事件中心，事件中心表示流管道的入口点。事件流（例如跨帐户和/或 Azure 订阅的已创建/已删除 Blob 的事件消息）正由 ASA 作业根据需要进行分析。ASA 作业的输出将触发 Azure 函数来完成业务需求。

有关事件中心作为事件网格目标的更多详细信息，请参见此处。

Answer 2

理想情况下，如果以反应式方式使用它们，即当函数直接（或通过事件网格）在 Blob 更改事件上运行时，函数的工作效果最佳。

如果您必须坚持使用计时器，然后查找所有更改的blob，Azure函数绑定将不会帮助您。在这种情况下，请删除您试图声明的输入绑定，并使用Blob存储API搜索已更改的Blob。我相信适用于节点的Azure存储SDK。js支持列出blob，但我没有使用它。