能否通过sns.Topic.fromTopicArn触发AWS CodePipeline执行？

方案一：直接通过EventBridge关联SNS与CodePipeline（无需Lambda） #

你可以不用Lambda，直接通过EventBridge规则捕获SNS消息事件，再将CodePipeline设为规则目标，这样收到SNS消息时就会触发流水线运行，逻辑和你用定时触发的方式类似，只是触发源换成了SNS事件。

CDK代码示例 #

import * as events from '@aws-cdk/aws-events';
import * as targets from '@aws-cdk/aws-events-targets';
import * as codepipeline from '@aws-cdk/aws-codepipeline';
import * as sns from '@aws-cdk/aws-sns';

// 引用已有的SNS主题
const consumerTopic = sns.Topic.fromTopicArn(
  this,
  "myTopicId",
  "arn:aws:sns:*******" // 替换为你的SNS主题ARN
);

// 声明已创建的CodePipeline
declare const pipeline: codepipeline.Pipeline;

// 创建EventBridge规则，捕获目标SNS的消息事件
const snsTriggerRule = new events.Rule(this, 'SnsTriggerPipelineRule', {
  eventPattern: {
    source: ['aws.sns'],
    detailType: ['Amazon SNS Notification'],
    resources: [consumerTopic.topicArn]
  }
});

// 将CodePipeline设为规则目标，触发流水线执行
snsTriggerRule.addTarget(new targets.CodePipeline(pipeline));

方案二：通过Lambda中转触发CodePipeline #

如果需要对SNS消息做额外处理（比如校验消息内容、过滤特定消息才触发流水线），可以用Lambda作为SNS订阅的接收端，在Lambda中调用CodePipeline的API触发流水线运行。

步骤1：CDK配置SNS订阅Lambda #

import * as sns from '@aws-cdk/aws-sns';
import * as lambda from '@aws-cdk/aws-lambda';
import * as subscriptions from '@aws-cdk/aws-sns-subscriptions';
import * as iam from '@aws-cdk/aws-iam';

// 引用已有的SNS主题
const consumerTopic = sns.Topic.fromTopicArn(
  this,
  "myTopicId",
  "arn:aws:sns:*******" // 替换为你的SNS主题ARN
);

// 创建Lambda函数
const triggerPipelineFn = new lambda.Function(this, 'TriggerPipelineFunction', {
  runtime: lambda.Runtime.NODEJS_16_X,
  handler: 'snsHandler.handler',
  code: lambda.Code.fromAsset(__dirname),
});

// 给Lambda添加触发CodePipeline的权限
triggerPipelineFn.addToRolePolicy(new iam.PolicyStatement({
  actions: ['codepipeline:StartPipelineExecution'],
  resources: ['你的CodePipeline ARN'] // 替换为你的流水线ARN
}));

// 将Lambda订阅到SNS主题
consumerTopic.addSubscription(new subscriptions.LambdaSubscription(triggerPipelineFn));

步骤2：Lambda处理代码（snsHandler.js） #

const AWS = require('aws-sdk');
const codepipeline = new AWS.CodePipeline();

exports.handler = async (event) => {
  // 可选：解析并校验SNS消息内容
  const snsMessage = JSON.parse(event.Records[0].Sns.Message);
  console.log('收到的SNS消息:', snsMessage);

  // 触发CodePipeline执行
  const params = {
    name: '你的CodePipeline名称' // 替换为你的流水线名称
  };

  try {
    await codepipeline.startPipelineExecution(params).promise();
    console.log('流水线触发成功');
    return { statusCode: 200, body: '流水线已触发' };
  } catch (error) {
    console.error('触发流水线失败:', error);
    throw error;
  }
};

注意事项 #

• 方案一适合无需额外处理消息的场景，配置更简单，无额外Lambda成本。
• 方案二适合需要消息过滤、内容校验或其他自定义逻辑的场景。
• 确保相关角色（EventBridge执行角色、Lambda执行角色）拥有codepipeline:StartPipelineExecution权限。

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