模式匹配blob名称到具有输入绑定的函数变量

Question

根据Azure Functions留档的Azure Blob存储绑定，在配置Blob触发器时，可以利用Blob名称上的模式匹配将部分路径映射到函数中的变量，例如。

[FunctionName("BlobTriggered")]        
public static void BlobTriggered(
    [BlobTrigger("myContainer/{name}.{extension}")] Stream myBlob,
    string name,
    string extension,
    TraceWriter log)
{
    // Given the blob path "myContainer/myBlob.png":
    // name == "myBlob"
    // extension == "png"
}

我已经测试过了，它在我的用例中运行得很好，但是由于< code>BlobTrigger触发的大延迟(通常超过5分钟),它不是一个可行的选项。因此，根据Azure Functions scale和托管文档的建议，我希望将它变成一个事件网格触发器:

当您在消费计划中使用blob触发器时，处理新的blob可能会延迟10分钟。此延迟发生在功能应用程序空闲时。函数应用程序运行后，将立即处理blob。要避免这种冷启动延迟，请使用始终启用的应用程序服务计划，或使用事件网格触发器。

是否有任何方法可以从输入绑定而不是触发器获得相同的模式匹配行为？

在我的具体情况下，我已经为blob创建设置了一个< code>EventGrid订阅，它运行一个orchestrator函数，调用一个activity函数来读取和解析blob:

[FunctionName("NewBlobCreated")]
public static async Task NewBlobCreated(
    [EventGridTrigger]EventGridEvent eventGridEvent,
    [OrchestrationClient]DurableOrchestrationClient starter,
    ILogger log)
{
    // Start our orchestrator function to read the file
    string instanceId = await starter.StartNewAsync(
        "OrchestrateBlobReader",
        eventGridEvent);
}

// Orchestrator function
[FunctionName("OrchestrateBlobReader")]
public static async Task OrchestrateBlobReader(
    [OrchestrationTrigger] DurableOrchestrationContext context,
    ILogger log)
{
    var eventGridEvent = context.GetInput<EventGridEvent>();
    var parsedBlob = await context.CallActivityAsync<string>("ReadBlob", eventGridEvent.Data);        
    ...
}

[FunctionName("ReadBlob")]
public static async Task<string> ReadBlob(
    [ActivityTrigger] JObject eventData,
    [Blob("{data.url}", FileAccess.Read)]CloudBlockBlob blob,
    ILogger log)
{
    using (var blobStream = await blob.OpenReadAsync())
    {
        // Blob is able to be read from blobStream here
        ...
    }
}

理想情况下，我希望我的 ReadBlob 函数的行为类似于上面第一个示例中的 BlobTriggered 函数，以便执行如下操作：

[FunctionName("ReadBlob")]
public static async Task<string> ReadBlob(
    [ActivityTrigger] JObject eventData,
    [Blob("{data.url}", FileAccess.Read)]CloudBlockBlob blob,
    string extension,
    ILogger log)
{
    if (extension.Equals("txt", StringComparison.OrdinalIgnoreCase))
    { ... }
    else if (extension.Equals("png", StringComparison.OrdinalIgnoreCase)
    { ... }
    else
    { ... }
}

问题是我看不到任何方法可以将扩展参数绑定到Blob输入绑定，就像我为BlobTrigger所做的那样 - 特别是将路径绑定到EventGridEvent以eventData JObject形式提供的URL。

在这种情况下，是否有可能实现相同的模式匹配功能？还是我必须自己解析路径字符串以提取相关信息？

Answer 1

在查看了 blob 触发器绑定的源代码之后 - 我的“快速和肮脏”解决方案是利用触发器用于映射路径的基础 BindingTemplateSource 类

更新后的< code>ReadBlob函数如下:

// So we can access the BindingTemplateSource class
using Microsoft.Azure.WebJobs.Host.Bindings.Path;

[FunctionName("ReadBlob")]
public static async Task<string> ReadBlob(
    [ActivityTrigger] JObject eventData,
    [Blob("{data.url}", FileAccess.Read)]CloudBlockBlob blob,
    ILogger log)
{
    // Define the pattern to match
    var blobPattern = "myContainer/{name}.{extension}";
    // Create a BindingTemplateSource from the pattern string
    var patternTemplate = BindingTemplateSource.FromString(blobPattern);
    // Use this BindingTemplateSource to create the binding data
    // This returns a IReadOnlyDictionary<string, object> with the parameters mapped
    var parameters = patternTemplate.CreateBindingData($"{blob.Container.Name}/{blob.Name}");
    // Assuming blob path was "myContainer/myBlob.png":
    // Parameters are objects so we need to ToString() them
    var name = parameters["name"].ToString(); // name == "myBlob"
    var extension = parameters["extension"].ToString(); // extension == "png"

    if (extension.Equals("txt", StringComparison.OrdinalIgnoreCase))
    { ... }
    else if (extension.Equals("png", StringComparison.OrdinalIgnoreCase))
    { 
        // This executes now!
    }
    else
    { ... }
}

然后，该功能可能会包装在自定义绑定中，其中参数映射到函数上的输出绑定，就像＜code＞BlobTrigger＜/code＞为最优雅的解决方案所做的那样，但像这样将其破解到函数中可以实现我短期所需的功能