我是Azure Function应用程序中blob触发器的新手,需要一些帮助。我正在努力寻找有关如何重命名触发该函数的blob的资源。
我有一个函数应用程序,当一个新的blob被上传到容器时触发,文件被处理,我需要一种方法来将其“标记”为已处理,因此我想重命名blob。
这是我的职责:
[FunctionName("ProcessFile")]
public async Task Run([BlobTrigger("storage-test-container/{name}", Connection = "BlobConnection")] Stream myBlob
, [Blob("storage-test-container/{name}", FileAccess.Write)] Stream outboundBlob, string name, ILogger log)
{
using (var reader = new StreamReader(myBlob))
{
var textAsString = await reader.ReadToEndAsync();
// Process text then rename file ...
}
}
我该如何重命名该文件?在这种情况下有可能吗?
您可以从触发器路径中使用 {name}。
Console.WriteLine("This is the filename: " + name);
如何重命名文件?
考虑到本机不支持重命名blob,您需要做的是复制具有不同名称的源blob,然后将其删除。这相当于重命名一个blob。
在这种情况下有可能吗?
尽管这样做在技术上是可能的,但我不建议这样做。当您复制blob时,将创建一个新的blob,这将再次触发您的Function。因此,您将最终陷入无限循环。
更好的方法是创建一个单独的blob容器(例如< code > storage-test-container-processed ),然后将源blob复制到该容器,并在blob复制成功后将其删除。本质上你将移动一个blob,而不是重命名它。
我遇到的情况是,Blob可能在第一次处理时失败,但可能在后续执行中工作。 我遇到的问题是关于监控真正的失败,目前第一次失败将抛出一个异常,该异常被记录并发出警报,但如果第一次重试成功完成,那么根据早期警报就没有什么可做的了。 是否有办法查看已发生的重试次数,以便我只能在不再重试时发出警报?
如果你使用blob存储触发器阅读Azure WebJobs上的留档,它们会提到这不是很可靠: WebJobs SDK扫描日志文件以查看新的或更改的blob。这个过程不是实时的;在创建blob后的几分钟或更长时间内,函数可能不会被触发。此外,存储日志是在“尽力而为”的基础上创建的;无法保证所有事件都将被捕获。在某些情况下,日志可能会丢失。如果您的应用程序无法接受blob触发器的速度和可靠性限制,建议
我使用blob触发器读取blob内容,作为pandas DF进行处理,并将blob附加到我使用的Azure SQL server。 blob触发器没有按预期工作,因此我将main函数中的所有代码都定义为: 但是,我得到了以下错误: 有人可以帮助我找到此问题的原因吗? function.json的配置如下:
我有一个azure函数,由上传到特定容器的任何新blob(图像)触发。这些图像然后被存储在这个blob存储容器中。现在我改变了我的函数并重新部署它,我希望我的azure函数能够在所有这些(已经存储的)图像上重新运行。由于该功能是blob触发的,现在我只是手动重新上传存储容器中的相同图像,但随着图像数据的增加,这样做变得越来越不可行。 函数中的Blob触发器如下所示: 它的解决方案是什么? 谢谢你。
我有两个blob触发器,我想触发。一个有效,一个无效! 我使用Azure Storage Explorer来确保blob被上传到每个blob,< code>scanFiles永远不会触发,而< code>scanExports似乎总是会触发。 问题:什么会导致某些blob无法触发Azure函数?
Azure函数存储帐户Blob容器触发器 在我们的一个用例中,我正在为具有以下条件的存储帐户容器中的任何活动寻找Azure函数触发器 < li >具有特定命名约定的容器(名称如xxxx-input) < li >它应该自动检测是否创建了新的容器(具有特定的命名约定) < li>