如何在AWS CDK v2部署流程中自动注册Telegram Bot Webhook？

完全可以在CDK部署过程中自动完成Telegram Webhook的注册，推荐用**CDK自定义资源（Custom Resource）**实现，这是最贴合基础设施即代码理念的方式，能把Webhook注册纳入部署生命周期，失败时会随栈回滚。

实现步骤 #

1. 编写负责注册Webhook的Lambda函数 #

这个Lambda会读取Secrets Manager中的Telegram Bot Token，调用Telegram的Webhook API完成注册。示例代码（Python）：

import json
import boto3
import requests

secrets_manager = boto3.client('secretsmanager')

def handler(event, context):
    # 从自定义资源参数中获取API Gateway URL和Secret ARN
    api_gateway_url = event['ResourceProperties']['ApiGatewayUrl']
    secret_arn = event['ResourceProperties']['TelegramBotSecretArn']
    
    # 获取Telegram Bot Token
    secret_response = secrets_manager.get_secret_value(SecretId=secret_arn)
    bot_token = json.loads(secret_response['SecretString'])['token']
    
    # 构造Telegram Webhook请求URL
    telegram_webhook_url = f"https://api.telegram.org/bot{bot_token}/setWebhook"
    
    # 发起GET请求注册Webhook
    response = requests.get(telegram_webhook_url, params={'url': api_gateway_url})
    
    if response.status_code != 200 or not response.json().get('ok'):
        raise Exception(f"Webhook注册失败: {response.text}")
    
    return {
        'Status': 'SUCCESS',
        'PhysicalResourceId': context.log_stream_name,
        'Data': {'Message': 'Webhook注册成功'}
    }

2. 在CDK栈中集成自定义资源 #

在你的CDK代码中，定义这个Lambda和自定义资源，确保它依赖API Gateway的部署（保证URL已生成）。示例TypeScript代码：

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as secretsmanager from 'aws-cdk-lib/aws-secretsmanager';
import * as cr from 'aws-cdk-lib/custom-resources';

export class TelegramBotStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    // 假设你已经定义了API Gateway和对应的部署
    const api = // 你的API Gateway实例
    const apiDeployment = new cdk.aws_apigateway.Deployment(this, 'ApiDeployment', { api });
    const apiUrl = api.url;

    // 引用存储Telegram Bot Token的Secrets Manager密钥
    const botSecret = secretsmanager.Secret.fromSecretNameV2(this, 'TelegramBotSecret', 'your-secret-name');

    // 创建注册Webhook的Lambda函数
    const webhookRegisterLambda = new lambda.Function(this, 'WebhookRegisterLambda', {
      runtime: lambda.Runtime.PYTHON_3_11,
      code: lambda.Code.fromAsset('path/to/lambda/code'),
      handler: 'index.handler',
    });
    botSecret.grantRead(webhookRegisterLambda);

    // 定义自定义资源，触发Lambda执行注册
    new cr.AwsCustomResource(this, 'RegisterTelegramWebhook', {
      onCreate: {
        service: 'Lambda',
        action: 'invoke',
        parameters: {
          FunctionName: webhookRegisterLambda.functionName,
          Payload: JSON.stringify({
            ResourceProperties: {
              ApiGatewayUrl: apiUrl,
              TelegramBotSecretArn: botSecret.secretArn
            }
          })
        },
        physicalResourceId: cr.PhysicalResourceId.fromResponse('Payload')
      },
      // 依赖API部署，确保URL已生成
      resources: [apiDeployment.node.path],
      policy: cr.AwsCustomResourcePolicy.fromSdkCalls({
        resources: cr.AwsCustomResourcePolicy.ANY_RESOURCE
      })
    });
  }
}

替代方案：Post-Deployment脚本 #

如果不想用自定义资源，也可以写一个shell脚本，在cdk deploy执行完成后手动或自动调用：

#!/bin/bash

# 获取API Gateway URL
API_URL=$(aws cloudformation describe-stacks --stack-name YOUR_STACK_NAME --query "Stacks[0].Outputs[?OutputKey=='ApiGatewayUrl'].OutputValue" --output text)

# 获取Telegram Bot Token
BOT_TOKEN=$(aws secretsmanager get-secret-value --secret-id YOUR_SECRET_NAME --query "SecretString" --output text | jq -r '.token')

# 注册Webhook
curl "https://api.telegram.org/bot${BOT_TOKEN}/setWebhook?url=${API_URL}"

执行命令：cdk deploy && ./register-webhook.sh
但这种方式不纳入CDK的部署生命周期，若CDK部署失败仍会执行脚本，且依赖本地环境配置AWS CLI和jq。

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