已部署但未触发的Azure Blob触发函数问题及功能扩展咨询

• 触发绑定配置错误：检查function.json：
  • 确认type为blobTrigger
  • path需匹配上传文件所在的Blob容器路径（格式如{容器名}/{可选前缀}/{文件名}）
  • connection对应的应用设置项，必须包含有权限访问目标存储账户的连接字符串
• 文件过滤规则不匹配：如果path中指定了后缀过滤（比如sample-container/{name}.txt），上传的.toml文件会被忽略，需调整为sample-container/{name}.toml或不限制后缀
• 存储账户权限不足：函数使用的身份（系统身份或连接字符串）没有目标Blob容器的读取和列出权限，无法检测到新文件上传
• 函数应用配置问题：确认函数确实处于已启用状态，且函数应用本身没有被暂停

首先，确保函数部署包包含依赖：azure-storage-blob、toml（如果脚本需要）等，在requirements.txt中声明。

修改后的示例代码如下：

import logging
import azure.functions as func
import subprocess
import tempfile
import os
from azure.storage.blob import BlobServiceClient

def main(myblob: func.InputStream):
    logging.info(f"处理Blob文件: {myblob.name}, 大小: {myblob.length} bytes")
    
    # 从应用设置中读取目标存储连接字符串（避免硬编码）
    target_connection_string = os.environ.get("TARGET_STORAGE_CONNECTION_STRING")
    target_container_name = "<目标容器名>"
    blob_service_client = BlobServiceClient.from_connection_string(target_connection_string)
    
    # 将输入Blob保存为临时TOML文件
    with tempfile.NamedTemporaryFile(mode='w+b', suffix='.toml', delete=False) as temp_file:
        temp_file.write(myblob.read())
        temp_file_path = temp_file.name
    
    try:
        # 运行GitHub项目中的Python脚本（假设代码已打包进函数部署包）
        result = subprocess.run(
            ["python", "src/main.py", temp_file_path],
            check=True,
            capture_output=True,
            text=True
        )
        logging.info(f"脚本运行输出: {result.stdout}")
        
        # 上传生成的文件到目标Blob（示例假设脚本生成output.toml）
        output_file_name = f"processed_{os.path.basename(myblob.name)}"
        target_blob_client = blob_service_client.get_blob_client(
            container=target_container_name,
            blob=output_file_name
        )
        
        with open("output.toml", "rb") as output_file:
            target_blob_client.upload_blob(output_file, overwrite=True)
            logging.info(f"生成的文件已上传至Blob: {target_container_name}/{output_file_name}")
            
    except subprocess.CalledProcessError as e:
        logging.error(f"脚本运行失败: {e.stderr}")
        raise
    except Exception as e:
        logging.error(f"处理过程出错: {str(e)}")
        raise
    finally:
        # 清理临时文件和生成文件
        if os.path.exists(temp_file_path):
            os.remove(temp_file_path)
        if os.path.exists("output.toml"):
            os.remove("output.toml")

额外注意事项 #

• GitHub代码部署：建议将GitHub项目代码直接包含在Azure Function的部署目录中，而非每次触发克隆，避免网络延迟和权限问题
• 环境变量管理：所有敏感信息（如存储连接字符串）都应存入函数应用的应用设置，通过os.environ读取
• 资源清理：函数执行完成后务必清理临时文件和生成文件，避免占用函数应用的存储资源

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