我如何触发已经在blob中的blob触发的azure函数？

Question

我有一个azure函数，由上传到特定容器的任何新blob(图像)触发。这些图像然后被存储在这个blob存储容器中。现在我改变了我的函数并重新部署它，我希望我的azure函数能够在所有这些(已经存储的)图像上重新运行。由于该功能是blob触发的，现在我只是手动重新上传存储容器中的相同图像，但随着图像数据的增加，这样做变得越来越不可行。

函数中的Blob触发器如下所示：

def main(myblob: func.InputStream, doc: func.Out[func.Document]):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"
                 f"Blob Size: {myblob.length} bytes")

    blob_val = myblob.read()
    .
    .
    .

它的解决方案是什么？

谢谢你。

Answer 1

不能利用 HTTP 请求正文，然后将值提供给 Blob 的输入绑定。另一个选项是在 HTTP 请求中包含参数，然后在 Blob 输入绑定的路径中使用该参数。

如果在函数的HTTP请求参数中未正确传递blob名称，则它将不会像您将函数定义为接收InputStream那样执行。

HTTP请求URL:HTTP://{ yourfunctionapp }/API/HTTP trigger 1？blobname=sample.txt

如果示例文本文件不在所配置的存储帐户的容器输入中，则您的函数将失败，这意味着如果输入的blob名称不正确，将返回500错误。

def main(req: func.HttpRequest, i*_nputblob: func.InputStream_*) -> func.HttpResponse:

函数. json

{
   "scriptFile": "__init__.py",
   "bindings": [
     {
       "authLevel": "anonymous",
       "type": "httpTrigger",
       "direction": "in",
       "name": "req",
       "methods": [
         "get",
         "post"
       ]
     },
     {
       "name": "inputblob",
       "type": "blob",
       "path": "input/{blobname}",
       "connection": "AzureWebJobsStorage",
       "direction": "in"
     },
     {
       "type": "http",
       "direction": "out",
       "name": "$return"
     }
   ]
 }

或者，您只能使用HTTP输入绑定，并且您必须开发自己的代码来通过HTTP主体输入与存储服务进行通信。