如何使用Python中Azure函数的Azure blob存储绑定将JSON数据上载到Azure存储blob

Question

我想使用Python中的Azure函数将JSON数据作为. json文件上传到Azure存储Blob。

因为我使用的是Azure函数，而不是实际的服务器，所以我不想（也可能无法）在本地内存中创建一个临时文件，并使用Azure blob存储客户端库v2将该文件上载到Azure blob存储。1对于Python（这里有参考链接）。因此，我想为Azure函数使用输出blob存储绑定（这里有参考链接）。

我正在一个带有HTTP触发器的Azure函数中测试此功能。我通过输入blob存储绑定（工作正常）接收Azure blob，处理它，并通过上传一个覆盖它的新Azure blob来更新它（这就是我需要的帮助）。我的function.json文件是这样的：

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

我的Python代码是这样的：

import logging
import azure.functions as func
import azure.storage.blob
from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient
import json, os

def main(req: func.HttpRequest, inputblob: func.InputStream, outputblob: func.Out[func.InputStream]) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

    # Initialize variable for tracking any changes
    anyChanges= False

    # Read JSON file
    jsonData= json.loads(inputblob.read())

    # Make changes to jsonData (omitted for simplicity) and update anyChanges

    # Upload new JSON file
    if anyChanges:
        outputblob.set(jsonData)

    return func.HttpResponse(f"Input data: {jsonData}. Any changes: {anyChanges}.")

然而，这根本不起作用，抛出以下错误（截图）：

价值函数。“退出”是不可订阅的

我错过了什么？

Answer 1

您想要的是字节或str，而不是输入流，如下所示：

def main(inputblob: func.InputStream, outputblob: func.Out[bytes], context: func.Context):
    ...
    # Write to output blob
    outputblob.set(jsonData)

InputStream表示一个输入Blob。

查看str的此示例，以及bytes的此示例。

后期更新：

调用json。loads（）返回一个字典，出于某种原因，输出blob。set（）吓了一跳，需要一些把手，比如：

def main(req: func.HttpRequest,
         inputblob: func.InputStream,
         outputblob: func.Out[bytes]) -> func.HttpResponse:

    jsonData = json.loads(inputblob.read())
    outputblob.set(str(jsonData))

    return func.HttpResponse(f"Input JSON: {jsonData}")

这应该行得通（至少在funcversion2.7.1948上可以）。