使用blob存储输入和输出Python的事件网格触发器Azure函数

Question

我正在寻找合适的资源/教程，可以帮助我开发和部署事件网格触发器，该触发器将等待图像上传到blob容器，使用python处理该图像，然后将结果保存在另一个blob容器中。我发现了许多单独的文档，它们不一定在逻辑上指导我使用Azure Portal和VSCode进行开发和部署，就像从头到尾的一步一步的演练，介绍了实现这一点的所有步骤。

任何指导将不胜感激。

Answer 1

我不推荐你直接用Azure portal开发。而且既然需要使用基于Python开发Azure function，那么就需要使用Azure function核心工具。

1、下载并安装Azure功能核心工具。（下载函数3.x）

https://docs . Microsoft . com/en-us/azure/azure-函数/函数-运行-本地？tabs=windows，csharp，bash#v2

并且需要安装python 3.8.x(请注意必须下载64bit。否则功能应用程序在启动时将会出错。)

2、配置Python到系统路径。

3，在VS代码中安装函数扩展和Python调试扩展。

4、按f1并输入'func'，您将找到创建功能选项。

5、按照创建函数的步骤操作。然后使用以下代码：

function.json代码

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "eventGridTrigger",
      "name": "event",
      "direction": "in"
    },
    {
      "name": "inputblob",
      "type": "blob",
      "path": "test1/6.txt",
      "connection": "MyStorageConnectionAppSetting",
      "direction": "in"
    },
    {
      "name": "outputblob",
      "type": "blob",
      "path": "test2/6.txt",
      "connection": "MyStorageConnectionAppSetting",
      "direction": "out"
    }
  ]
}

local.settings.json代码

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "",
    "FUNCTIONS_WORKER_RUNTIME": "python",
    "MyStorageConnectionAppSetting":"DefaultEndpointsProtocol=https;AccountName=0730bowmanwindow;AccountKey=xxxxxx==;EndpointSuffix=core.windows.net"
  }
}

__init__py

import json
import logging

import azure.functions as func


def main(event: func.EventGridEvent, inputblob: func.InputStream, outputblob: func.Out[func.InputStream]):
    result = json.dumps({
        'id': event.id,
        'data': event.get_json(),
        'topic': event.topic,
        'subject': event.subject,
        'event_type': event.event_type,
    })

    logging.info('Python EventGrid trigger processed an event: %s', result)

    #Do something here. you can change below inputblob to other stream.

    outputblob.set(inputblob)

完成上述所有步骤后，创建事件网格订阅并将功能应用程序部署到azure。将事件网格指向函数应用程序。然后，当事件发生时，该功能将被触发。

您需要注意的是，Python不支持绑定器，因此…无法在运行时指定路径。（这很遗憾。Ibinder仅支持基于.Net的语言。）

以上是你的要求，它可以工作，但是blob路径不能是动态的...我认为对于你的情况，更合适的方法是使用blob触发器和blob输出绑定。（这可以从触发器到输出获取blob名称。）