如何从Azure Synapse文件创建触发器获取Blob存储文件创建者

方法1：通过Blob存储API查询元数据 #

Blob存储的事件触发器本身不会直接返回创建者信息，你需要在触发后的Synapse管道中添加额外步骤，调用Blob存储的REST API获取Blob元数据：

• 调用API端点：GET https://<存储账户名>.blob.core.windows.net/<容器名>/<文件名>?comp=metadata
• 响应头中的x-ms-blob-created-by字段即为创建该Blob的用户ID或UPN

具体实现步骤 #

1. 在Synapse管道中添加Web活动，配置如下：
   • URL：用表达式拼接生成，示例：@concat('https://', pipeline().parameters.storageAccountName, '.blob.core.windows.net/', pipeline().parameters.containerName, '/', triggerBody().fileName, '?comp=metadata')
   • 请求方法：GET
   • 授权方式：选择「账户密钥」并填入存储账户访问密钥，或使用Azure AD身份验证
2. 执行Web活动后，通过表达式@activity('Web活动名称').output.headers['x-ms-blob-created-by']提取创建者信息

方法2：通过Azure Monitor诊断日志查询 #

若存储账户已启用诊断日志，可在Synapse中添加Lookup活动，查询StorageBlobLogs表获取创建者信息：

• KQL查询示例：

  StorageBlobLogs
  | where AccountName == '<存储账户名>'
  | where ContainerName == '<容器名>'
  | where ObjectName == @triggerBody().fileName
  | where OperationName in ('PutBlob', 'PutBlockList')
  | project CallerIdentity, ObjectName, EventTime
  | take 1
  

• 查询结果中的CallerIdentity字段即为文件创建者的身份信息

注意事项 #

• 方法1需确保管道具备访问Blob存储API的权限，避免权限不足报错
• 方法2需提前开启存储账户的诊断日志，否则无法查询到相关数据
• 若Blob是通过Synapse/ADF服务主体写入的，CallerIdentity会显示服务主体信息而非个人用户

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