问题标签 [azure-blob-trigger]

我在 C# 中有一个相当简单的 blob 触发器，它只是在上传文件时将文件从一个容器复制到另一个容器。令人沮丧的是，每当我从 Visual Studio 发布触发器时，它都会重新运行所有文件并重新复制它们（然后可能会运行 100 多个逻辑应用实例来处理新文件）。有什么方法可以阻止触发器在旧文件上重新运行，也许是我错过的属性或过滤器？否则我可以在我的代码中使用最后修改的过滤器，但如果它是内置的更好。非常感谢。

我创建了一个 ADF 管道，当将 blob 添加到存储容器（例如 container1）并将 blob 复制到另一个存储容器（例如 container2）时应该触发该管道。我所有的 blob 名称都是带有“-”的字母数字（基本上是 GUID）。我看到与容器 1 中的 blob 数量相比，ADF 仅触发了几次（即，如果容器 1 中有 n 个文件，则 ADF 仅触发 x 次，其中 x<n）。

我还观察到，每当 container1 中每秒创建的 blob 很高时，就会有更多的错过触发器。我没有在事件网格中使用任何事件批处理。我的存储帐户是 v2 BlockBlobStorage。

有没有办法解决这个问题？

我正在尝试使用 Blob 触发器在本地调试 Azure 函数。将图像文件上传到 Azure 时，我在本地运行的函数会收到触发器。

我的function.json

Image.open(blobin)线路运行时我得到的错误是：

System.Private.CoreLib：执行函数时出现异常：Functions.ResizePhoto。System.Private.CoreLib：结果：失败异常：UnidentifiedImageError：无法识别图像文件 <_io.BytesIO object at 0x0000017FD4FD7F40>

有趣的是，图像本身确实会在 VSCode 监视窗口中打开，但在运行代码时会失败。如果我再次将其添加到手表（可能会触发手表刷新），它也会给出与上述相同的错误。

我正在尝试创建一个 Blob 触发器，该触发器将在视频上传到特定容器时启动媒体服务作业。我不知道如何在函数应用程序中从该 blob 创建输入资产。AMS v2 对此有明确的文档，但我似乎找不到任何对 v3 有帮助的东西。

我创建了一个 blob 触发器，它接受来自 blob 的文件，将其解压缩并使用流将其移动到另一个 blob。

我的代码看起来像这样

实际上，这将在我的 local.settings.json 文件中使用“AzureWebJobsStorage”：“UseDevelopmentStorage=true”在本地运行时起作用。

但是，一旦我部署了这个应用程序并使用 Azure 存储资源管理器将文件上传到真实容器，什么都没有发生，并且活动日志显示操作在 Write.Tiny.txt.gz 中失败，找不到文件'D:\home \site\wwwroot\Requests\tiny.txt.gz'。

我有可以工作的 http 触发器，并且我尝试关闭配置 WEBSITE_RUN_FROM_PACKAGE 无效。我可能缺少一些设置或配置吗？当我在函数应用程序中控制台进入此路径并 cat function.json 时，我得到以下信息：

我编写了一个 IoT 中心触发器，它在接收到数据时触发，并使用输出绑定将其写入 Datalake 存储。

当前输出绑定：

但我想指定输出应动态写入的路径，如下所示：

这是我编写的代码，似乎没有实现它。

完整代码：

谁能让我知道我哪里出错了或者我可以动态编写它的方式。

我的问题是：我尝试在 Azure Function App 服务中执行一个新上传的 python 函数并启动它（无论我使用 blob 触发器还是 http 触发器）我总是得到同样的错误：

为什么会发生这种情况：当函数成功部署时，我在一个 blob 中上传了一个文件以触发该函数，但我总是遇到同样的错误，这是由 pathlib 库引起的（https://pypi.org/project/pathlib/）。我编写了一个非常简单的函数，可以在我的本地 vscode 中运行，它只是打印一条消息。

def main(myblob: func.InputStream):

Pythonapp 类是：

我的 requirements.txt 文件是：

我创建了这个简单的函数，以检查是否可以在 Azure Functions 中上传最简单的示例，是否有任何我忘记的依赖项？

检查我发现的功能的状态：

------------更新1--------

该函数失败是因为 pathlib 导入，这是因为在函数的要求中它下载了这个库并且使用 AZ 函数失败。请参阅以下链接中的 requirements.txt 文件：https ://github.com/pitchmuc/adobe_analytics_api_2.0/blob/master/requirements.txt

我可以以某种方式排除它吗？

好吧，我无法为此提供答案，我做了一个walkarround。在这种情况下，我在 github 存储库中创建了该库的副本。在这个副本中，我删除了 requrements.txt 和 setup.py 中对 pathlib 的引用，因为这个库导致 AZ 函数 APPS 失败。顺便在项目的需求文件中引用项目，所以请注意我上面写的requiremnts文件并将aanalytics2引用更改为：

链接。

我在谷歌检查了很多例子，但没有一个对我有帮助：

使用 OSError 成功部署后 Azure 功能失败：[Errno 107]

https://github.com/Azure/azure-functions-host/issues/6835

https://docs.microsoft.com/en-us/answers/questions/39865/azure-functions-python-httptrigger-with-multiple-s.html

https://docs.microsoft.com/en-us/answers/questions/147627/azure-functions-modulenotfounderror-for-python-scr.html

缺少对 Python Azure 函数的依赖--> 没有捆绑器标志或 –build 远程

https://github.com/OpenMined/PySyft/issues/3400

我使用python azure 函数使用以下代码从 azure blob 获取触发器

当在 blob 中上传文件时，就会触发。但有时会低于错误。我没有设置和标题或任何东西来连接blob。（在绑定设置中使用连接字符串）。知道错误的原因是什么吗？

绑定

在 Azure 门户中，我创建了一个在创建 .zip 文件时触发的 Blob 存储事件。该事件的端点是一个服务总线主题。在本主题中，我有一个带有默认规则（过滤器 1=1）的订阅。

我想创建规则，它只会传递来自这个事件的消息。通常我会用 Label 属性做一个相关过滤器，但不幸的是，在来自 blob 存储的消息中，这个 Label 属性是空的。

我试过了：

• SQL过滤器： Subject like "%containers/my-test-container/%"

• 具有自定义属性的相关过滤器

但它没有用。

我得到的信息：

系统和自定义属性

消息文本：

难道我做错了什么？是否可以设置 blob 消息的 Label 属性？

我需要组合一个逻辑应用程序。如果/当一个新文件进入 blob 存储时，新文件将被移动到一个新位置，比如“XYZ”。

文件将移动到新位置 XYZ 的方式是，操作中的逻辑应用程序将连接到虚拟机，该虚拟机将运行 azcopy 工具并从 blob 存储中选择文件并将其放在新位置 XYZ

而且我是连接到虚拟机的逻辑应用程序的新手，并且在逻辑应用程序运行时以某种方式在虚拟机中触发 azcopy 命令。

Blob 存储、虚拟机和逻辑应用都在同一个资源组、同一个订阅中。

真的很感激一些指示。

1. 我听说我需要创建一个 ISE 才能使逻辑应用程序与虚拟机一起使用，但我不确定我是否真的需要这个。这是我看到的文章。 https://docs.microsoft.com/en-us/azure/logic-apps/connect-virtual-network-vnet-isolated-environment

这是唯一的方法吗？2) 如何从逻辑应用程序在虚拟机中运行 AZCopy 命令？

非常感谢你的帮助。