如何获取触发GCP Cloud Function的流水线执行者UserId并推送至Teams

1. 修正流水线变量并传递执行者ID到GCP文件元数据 #

先确认你使用的是构建还是发布流水线，两者的执行者ID变量不同：

• 构建流水线用$(Build.RequestedForId)
• 发布流水线用$(Release.RequestedForId)，你之前报错大概率是用错了变量名称

在流水线YAML的文件上传步骤中，通过gsutil命令把执行者ID作为自定义元数据附加到上传文件上：

- script: |
    gsutil cp ./local-file-path gs://your-bucket-name/target-path \
    -h "x-goog-meta-requestedforid:$(Build.RequestedForId)" # 发布流水线替换为$(Release.RequestedForId)
  displayName: '上传文件到GCP Bucket并附加执行者ID元数据'

2. 修改Cloud Function读取元数据并推送至Teams #

更新你的Cloud Function代码，从触发事件里提取文件的自定义元数据，再发送消息到Teams通道：

Python示例 #

import requests
import os

def send_teams_notification(event, context):
    # 从事件中获取文件元数据
    file_metadata = event.get('metadata', {})
    user_id = file_metadata.get('x-goog-meta-requestedforid', '未知执行者')
    
    # 从环境变量读取Teams Webhook URL（避免硬编码）
    teams_webhook = os.environ.get('TEAMS_WEBHOOK_URL')
    if not teams_webhook:
        print("未配置Teams Webhook URL环境变量")
        return
    
    # 构造Teams消息
    message_payload = {
        "text": f"文件上传触发Cloud Function\n执行者ID: {user_id}"
    }
    
    # 发送消息到Teams
    try:
        response = requests.post(teams_webhook, json=message_payload)
        response.raise_for_status()
        print("消息已推送至Teams")
    except Exception as e:
        print(f"推送失败: {str(e)}")

Node.js示例 #

const axios = require('axios');

exports.sendTeamsNotification = async (event) => {
    const fileMetadata = event.metadata || {};
    const userId = fileMetadata['x-goog-meta-requestedforid'] || '未知执行者';
    
    const teamsWebhook = process.env.TEAMS_WEBHOOK_URL;
    if (!teamsWebhook) {
        console.log('未配置Teams Webhook URL环境变量');
        return;
    }
    
    const messagePayload = {
        text: `文件上传触发Cloud Function\n执行者ID: ${userId}`
    };
    
    try {
        await axios.post(teamsWebhook, messagePayload);
        console.log('消息已推送至Teams');
    } catch (error) {
        console.error('推送失败:', error.message);
    }
};

3. 配置Cloud Function环境变量 #

在GCP控制台的Cloud Function设置中，添加环境变量TEAMS_WEBHOOK_URL，值为你在Teams通道创建的传入Webhook地址（创建方式：Teams通道→更多选项→连接器→传入Webhook）。

4. 验证变量可用性 #

如果不确定变量是否存在，可在流水线中加调试步骤输出变量值：

- script: echo "执行者ID: $(Build.RequestedForId)" # 发布流水线替换为$(Release.RequestedForId)
  displayName: '调试：输出执行者ID'

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