Azure Function仅含POST接口，PySpark存响应至Blob遇空白问题求助

现有代码的问题 #

• 未发送POST请求：http.client.HTTPSConnection初始化后，没有调用request()方法发送POST请求就直接获取响应，自然返回空白。
• JSON处理冗余：json.loads(json.dumps(data))完全多余，data是响应字符串，这样操作后还是原字符串，反而可能引入格式问题。
• 缺少必要请求配置：未设置请求头（如Content-Type: application/json），若API需要请求体也未传入。

正确的实现步骤 #

1. 正确调用POST API #

使用http.client发送POST请求的示例代码：

import http.client
import json

# 拆分API路径：提取主机和路径部分，比如API路径是https://xxx.azurewebsites.net/api/func，主机是xxx.azurewebsites.net，路径是/api/func
host = "<API主机地址>"
path = "<API路径部分>"

# 初始化连接
conn = http.client.HTTPSConnection(host)

# 构造请求头，根据API要求调整
headers = {
    'Content-Type': 'application/json'
}

# 若API需要请求体，构造对应的JSON数据，不需要则传空字符串
payload = json.dumps({
    # 这里填API要求的请求参数，比如"key": "value"
})

# 发送POST请求
conn.request("POST", path, payload, headers)

# 获取响应
res = conn.getresponse()
data = res.read().decode("utf-8")

# 解析为JSON对象（如果响应是JSON格式）
try:
    jsondata = json.loads(data)
except json.JSONDecodeError:
    print("响应不是有效的JSON格式")
    jsondata = None

conn.close()

2. 将JSON数据存储到Blob存储 #

使用Azure官方SDK azure-storage-blob 来实现存储，先确保已安装依赖：pip install azure-storage-blob

示例代码：

from azure.storage.blob import BlobServiceClient

# Blob存储连接字符串，可从Azure门户获取
connect_str = "<Blob存储连接字符串>"
# 容器名称
container_name = "<容器名称>"
# 要创建的Blob文件名
blob_name = "response.json"

# 初始化Blob服务客户端
blob_service_client = BlobServiceClient.from_connection_string(connect_str)

# 获取容器客户端（若容器不存在，可先创建：blob_service_client.create_container(container_name)）
container_client = blob_service_client.get_container_client(container_name)

# 将JSON数据转为字符串写入Blob
if jsondata is not None:
    blob_client = container_client.get_blob_client(blob_name)
    blob_client.upload_blob(json.dumps(jsondata), overwrite=True)
    print("JSON数据已成功存储到Blob")
else:
    print("无有效JSON数据可存储")

注意事项 #

• 确保Azure Function的API密钥已正确配置：若API需要密钥，需在请求头中加入x-functions-key: <你的API密钥>。
• 处理异常：实际代码中需加入异常捕获（如网络连接错误、Blob存储权限错误等），保证稳定性。
• 权限配置：确保运行代码的身份（如本地环境的Azure账号、Azure Function的系统身份）有Blob存储的写入权限。

内容的提问来源于stack exchange，提问作者sudheer