【发布时间】:2022-01-23 09:34:30
【问题描述】:
我目前正在制作一个 Azure 函数,该函数在上传新文件时读取 blob 架构。每当上传新文件时,我都会使用 Blob Trigger Function 来触发它,但是从那里我被卡住了。有人可以帮忙吗?
【问题讨论】:
标签: python-3.x azure-functions
我目前正在制作一个 Azure 函数,该函数在上传新文件时读取 blob 架构。每当上传新文件时,我都会使用 Blob Trigger Function 来触发它,但是从那里我被卡住了。有人可以帮忙吗?
【问题讨论】:
标签: python-3.x azure-functions
以下是 Blod 触发器读取数据的示例代码。检查您的代码,这可能会帮助您解决问题。
{
"bindings": [
{
"queueName": "myqueue-items",
"connection": "MyStorageConnectionAppSetting",
"name": "queuemsg",
"type": "queueTrigger",
"direction": "in"
},
{
"name": "inputblob",
"type": "blob",
"dataType": "binary",
"path": "samples-workitems/{queueTrigger}",
"connection": "MyStorageConnectionAppSetting",
"direction": "in"
},
{
"name": "$return",
"type": "blob",
"path": "samples-workitems/{queueTrigger}-Copy",
"connection": "MyStorageConnectionAppSetting",
"direction": "out"
}
],
"disabled": false,
"scriptFile": "__init__.py"
}
这里是示例 python 代码。
import logging
import azure.functions as func
# The input binding field inputblob can either be 'bytes' or 'str' depends
# on dataType in function.json, 'binary' or 'string'.
def main(queuemsg: func.QueueMessage, inputblob: bytes) -> bytes:
logging.info(f'Python Queue trigger function processed {len(inputblob)} bytes')
return inputblob
有关完整信息,请查看此Blob Trigger 文档和Blob Trigger 输入绑定。
【讨论】: