Activepieces 集成 Amazon SNSSend Message 动作的配置、源码解析与构建指南【免费下载链接】activepiecesAI Agents MCPs AI Workflow Automation • (~400 MCP servers for AI agents) • AI Automation / AI Agent with MCPs • AI Workflows AI Agents • MCPs for AI Agents项目地址: https://gitcode.com/GitHub_Trending/ac/activepiecesActivepieces 的activepieces/piece-amazon-sns是一个轻量级集成组件Piece用于将消息发布Publish到 Amazon SNSSimple Notification Service主题从而把通知扇出到邮件、短信、HTTP/S、SQS、Lambda 等订阅端。本文以 packages/pieces/community/amazon-sns/README.md 为主线结合该 Piece 的认证定义、动作实现与构建脚本完整讲解从凭证配置、Region 选择、消息发送到本地构建验证的全过程并深入剖析其底层调用链。Piece 概览它能做什么Amazon SNS 是 AWS 的发布/订阅消息服务一个 Topic主题可以挂载多种类型的订阅者发布一条消息即可同时推送给所有订阅端。Activepieces 中的该 Piece 将「向 SNS 主题发送消息」封装为一个单动作action集成动作名称send-messageSend Message动作分类WRITE适用对象audience: both即普通流程与 AI Agent 工具场景均可使用支持触发器无triggers: []当前版本仅提供发送能力从 index.ts 的createPiece定义可以看到该 Piece 的显示名为 Amazon SNSminimumSupportedRelease为0.36.1作者为coat。它适用于告警通知、事件广播、系统状态推送等场景——例如流程中检测到异常时向运维 SNS 主题发送消息由主题按订阅协议分发给邮件组或短信接收人。前置准备AWS 侧需要什么在 Activepieces 中配置该 Piece 之前需要在 AWS 侧完成以下准备这是 AWS 账号层面的操作不属于仓库代码范围创建一个具有 SNS 发布权限的 IAM 用户为其生成 Access Key ID 与 Secret Access Key。最小权限建议仅包含sns:Publish和sns:ListTopics后者用于 Topic 下拉列表加载与凭证校验。预先创建好目标 SNS Topic或确认已有 Topic 的 ARN。确认 Topic 所在的 Region 与订阅协议邮件、SMS、HTTP/S、SQS、Lambda 等以便正确选择 Region 并验证消息投递。认证配置详解CustomAuth 与四个字段该 Piece 使用PieceAuth.CustomAuth定义了一套自有凭证结构而不是走 OAuth2 等托管认证。认证定义位于 index.ts共包含四个字段字段组件类型是否必填说明accessKeyIdProperty.ShortText是AWS IAM 访问密钥 IDsecretAccessKeyPieceAuth.SecretText是AWS 密钥密文存储不落明文日志regionProperty.StaticDropdown是SNS 服务所在区域内置 31 个 AWS Region 选项endpointProperty.ShortText否自定义服务端点常规使用留空Region 下拉内置 31 个 AWS 区域region字段是一个静态下拉StaticDropdown源码中硬编码了完整的区域清单覆盖全球主要 AWS 区域例如默认值us-east-1US East (N. Virginia)下拉的第一项即标记为 Default北美us-east-2、us-west-1、us-west-2、ca-central-1欧洲eu-central-1法兰克福、eu-west-1爱尔兰、eu-west-2伦敦、eu-west-3巴黎、eu-north-1斯德哥尔摩、eu-south-1米兰、eu-south-2西班牙、eu-central-2苏黎世亚太ap-east-1香港、ap-south-1孟买、ap-south-2海得拉巴、ap-southeast-1新加坡、ap-southeast-2悉尼、ap-southeast-3雅加达、ap-southeast-4墨尔本、ap-northeast-1东京、ap-northeast-2首尔、ap-northeast-3大阪本地其他区域af-south-1开普敦、me-south-1巴林、me-central-1阿联酋、sa-east-1圣保罗、cn-north-1北京、cn-northwest-1宁夏选择时需保证该区域与 Topic 的实际创建区域一致否则ListTopics与Publish将无法命中目标。Endpoint 字段本地/自定义端点调试入口endpoint为可选字段。从 common.ts 的实现可以看到它对空值与nil做了特殊处理endpoint: auth.endpoint || isNil(auth.endpoint) ? undefined : auth.endpoint,即留空时不会传给 AWS SDK客户端使用标准的 AWS 区域端点填入值时则将其作为SNSClient的显式端点。这个字段的实际价值在于对接 SNS 兼容的第三方实现或本地模拟服务如 LocalStack 类的 SNS 端点做联调测试。对正常使用云上 SNS 的用户官方说明明确要求留空。凭证校验连接时自动验证CustomAuth还定义了一个validate钩子index.ts保存/测试连接时它用当前凭证构造SNSClient并发送ListTopicsCommand若成功返回{ valid: true }失败则返回{ valid: false, error: message }把 AWS 返回的错误原文如权限不足、密钥错误、Region 不匹配直接暴露给用户。这意味着凭证错误在配置阶段就会被拦截而不是等到流程运行时才报错。Send Message 动作字段与行为动作定义位于 send-message.ts它只有两个输入属性属性组件类型必填说明topicProperty.Dropdown是目标主题 ARN运行时动态加载messageProperty.LongText是消息正文支持多行文本与表达式变量Topic 下拉运行时通过 ListTopics 动态加载topic是动态下拉它在动作渲染时调用 AWSListTopicsCommand拉取当前账号/Region 下全部主题label取 ARN 的最后一个冒号片段即主题名value存完整 ARN。该下拉对auth设置了refreshers: [auth]凭证变化时会自动重新加载选项未认证时返回disabled状态并提示 Please authenticate first无主题时提示 No topics found。需要留意的是下拉列表可能分页或数量较多且依赖sns:ListTopics权限如果 IAM 策略只授予了sns:Publish可以手动在流程变量中填入 ARN 使用构建时以代码为准。发送逻辑一次 PublishCommand 调用run方法的实现非常简洁核心只有两步const { topic, message } context.propsValue; const sns createSNS(context.auth.props); const response await sns.send(new PublishCommand({ TopicArn: topic, Message: message })); return response;它基于 AWS SDKaws-sdk/client-sns仓库锁定版本3.726.1见 package.json构造PublishCommand并直接返回 AWS 的响应对象包含MessageId等字段。从源码可以明确两点行为特征非幂等该动作的aiMetadata明确标注idempotent: false每次执行都会发布一条全新消息并再次投递给所有订阅端因此不适合用在可能重复触发的场景做「只发一次」的语义保证透传返回PublishCommand的响应会作为动作输出暴露给后续步骤流程中可以引用MessageId做日志关联或结果判断。底层原理createSNS 与 AWS SDK 客户端构造所有 AWS 调用都收敛到 common.ts 中的createSNS工厂函数export function createSNS(auth: { accessKeyId: string; secretAccessKey: string; region: string | undefined; endpoint: string | undefined; }) { const sns new SNSClient({ credentials: { accessKeyId: auth.accessKeyId, secretAccessKey: auth.secretAccessKey, }, region: auth.region, endpoint: auth.endpoint || isNil(auth.endpoint) ? undefined : auth.endpoint, }); return sns; }它把 Activepieces 的认证结构映射为SNSClient的credentials、region、endpoint三项配置。由于整个 Piece 只有这一个动作createSNS同时被三处复用认证validate校验、Topic 下拉加载、消息发送保证三处使用完全一致的客户端配置。从源码结构看后续若要扩展该 Piece例如增加CreateTopic、Subscribe等动作或 SNS 触发器只需要新增动作文件并沿用createSNS即可无需改动认证层。构建与本地验证README 中的构建命令原 README 的核心内容即构建方式使用 Turbo 以包过滤器构建该 Piece 库。turbo run build --filteractivepieces/piece-amazon-sns该命令在仓库根目录执行会触发 package.json 中定义的构建脚本build: tsc -p tsconfig.lib.json cp package.json dist/即先用tsc按tsconfig.lib.json编译 TypeScript 到dist/再把package.json拷贝进产物目录以保证发布包完整。除build外该包还提供turbo run lint --filteractivepieces/piece-amazon-sns # eslint 校验 src/**/*.ts bun run bundle # 通过 CLI 打包 piecepackage.json 中的 bundle 脚本bundle脚本内部调用 Activepieces CLI 的pieces bundle命令将 Piece 打包为可被运行时按需解析的产物。依赖方面该包只引入aws-sdk/client-sns3.726.1以及工作区内部的pieces-common、pieces-framework、core-piece-types、core-utils其余依赖如tslib仅用于开发构建保持了很轻的运行时体积。本地化与包信息该 Piece 的界面文案认证字段、Region 名称、动作显示名、提示语都做了 i18n 支持语言文件位于 src/i18n覆盖中文zh.json、德文、西班牙文、法文、日文、荷兰文、葡萄牙文、俄文、越南文等translation.json为英文默认文案。例如中文语言包中 Send Message 等字段键与默认文案一一对应说明该 Piece 的 UI 字符串全部经过翻译键提取流程。从 package.json 可以看到当前包版本为0.1.7属于workspace:*管理的 monorepo 子包结合 Piece 定义中minimumSupportedRelease: 0.36.1可以推断该 Piece 要求 Activepieces 运行时不低于 0.36.1 版本才能正常加载。使用注意事项与最佳实践结合源码行为汇总几条实战建议Region 必须与 Topic 一致Region 下拉有 31 个选项且有默认值us-east-1若 Topic 建在其他区域记得显式切换否则下拉加载不到目标主题。IAM 权限最小化至少需要sns:Publish发送与sns:ListTopics下拉加载 连接校验只读业务可再收紧为指定 Topic ARN 的资源级策略。连接测试先行保存连接时validate会真实调用 AWSListTopics趁此机会确认密钥与网络可达性避免把错误带到流程运行期。注意非幂等语义Publish每次执行都会投递一次涉及告警去重、消息上限等需求时应在流程层自行控制触发频率。利用返回的 MessageIdPublishCommand响应会透传给后续步骤可将其写入日志或作为审计依据。本地联调可填 Endpoint对接 SNS 兼容模拟器时填入对应端点云端使用则保持留空。小结activepieces/piece-amazon-sns是一个「小而精」的集成一个CustomAuth凭证结构、一个send-message动作、一个复用的SNSClient工厂即可把 AWS SNS 发布能力接入 Activepieces 的流程编排与 AI Agent 工具生态。本文从 README 的构建命令出发完整梳理了认证四字段Access Key ID、Secret Access Key、Region、Endpoint、动态 Topic 下拉、PublishCommand调用链与构建打包流程。需要扩展能力如订阅管理、主题创建、SNS 触发器的开发者可以以 src/lib/actions/send-message.ts 为模板新增动作并复用 src/lib/common.ts 的createSNS工厂保持与现有实现一致的风格与可靠性。【免费下载链接】activepiecesAI Agents MCPs AI Workflow Automation • (~400 MCP servers for AI agents) • AI Automation / AI Agent with MCPs • AI Workflows AI Agents • MCPs for AI Agents项目地址: https://gitcode.com/GitHub_Trending/ac/activepieces创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 Activepieces 集成 Amazon SNS：Send Message 动作的配置、源码解析与构建指南
Activepieces 集成 Amazon SNSSend Message 动作的配置、源码解析与构建指南【免费下载链接】activepiecesAI Agents MCPs AI Workflow Automation • (~400 MCP servers for AI agents) • AI Automation / AI Agent with MCPs • AI Workflows AI Agents • MCPs for AI Agents项目地址: https://gitcode.com/GitHub_Trending/ac/activepiecesActivepieces 的activepieces/piece-amazon-sns是一个轻量级集成组件Piece用于将消息发布Publish到 Amazon SNSSimple Notification Service主题从而把通知扇出到邮件、短信、HTTP/S、SQS、Lambda 等订阅端。本文以 packages/pieces/community/amazon-sns/README.md 为主线结合该 Piece 的认证定义、动作实现与构建脚本完整讲解从凭证配置、Region 选择、消息发送到本地构建验证的全过程并深入剖析其底层调用链。Piece 概览它能做什么Amazon SNS 是 AWS 的发布/订阅消息服务一个 Topic主题可以挂载多种类型的订阅者发布一条消息即可同时推送给所有订阅端。Activepieces 中的该 Piece 将「向 SNS 主题发送消息」封装为一个单动作action集成动作名称send-messageSend Message动作分类WRITE适用对象audience: both即普通流程与 AI Agent 工具场景均可使用支持触发器无triggers: []当前版本仅提供发送能力从 index.ts 的createPiece定义可以看到该 Piece 的显示名为 Amazon SNSminimumSupportedRelease为0.36.1作者为coat。它适用于告警通知、事件广播、系统状态推送等场景——例如流程中检测到异常时向运维 SNS 主题发送消息由主题按订阅协议分发给邮件组或短信接收人。前置准备AWS 侧需要什么在 Activepieces 中配置该 Piece 之前需要在 AWS 侧完成以下准备这是 AWS 账号层面的操作不属于仓库代码范围创建一个具有 SNS 发布权限的 IAM 用户为其生成 Access Key ID 与 Secret Access Key。最小权限建议仅包含sns:Publish和sns:ListTopics后者用于 Topic 下拉列表加载与凭证校验。预先创建好目标 SNS Topic或确认已有 Topic 的 ARN。确认 Topic 所在的 Region 与订阅协议邮件、SMS、HTTP/S、SQS、Lambda 等以便正确选择 Region 并验证消息投递。认证配置详解CustomAuth 与四个字段该 Piece 使用PieceAuth.CustomAuth定义了一套自有凭证结构而不是走 OAuth2 等托管认证。认证定义位于 index.ts共包含四个字段字段组件类型是否必填说明accessKeyIdProperty.ShortText是AWS IAM 访问密钥 IDsecretAccessKeyPieceAuth.SecretText是AWS 密钥密文存储不落明文日志regionProperty.StaticDropdown是SNS 服务所在区域内置 31 个 AWS Region 选项endpointProperty.ShortText否自定义服务端点常规使用留空Region 下拉内置 31 个 AWS 区域region字段是一个静态下拉StaticDropdown源码中硬编码了完整的区域清单覆盖全球主要 AWS 区域例如默认值us-east-1US East (N. Virginia)下拉的第一项即标记为 Default北美us-east-2、us-west-1、us-west-2、ca-central-1欧洲eu-central-1法兰克福、eu-west-1爱尔兰、eu-west-2伦敦、eu-west-3巴黎、eu-north-1斯德哥尔摩、eu-south-1米兰、eu-south-2西班牙、eu-central-2苏黎世亚太ap-east-1香港、ap-south-1孟买、ap-south-2海得拉巴、ap-southeast-1新加坡、ap-southeast-2悉尼、ap-southeast-3雅加达、ap-southeast-4墨尔本、ap-northeast-1东京、ap-northeast-2首尔、ap-northeast-3大阪本地其他区域af-south-1开普敦、me-south-1巴林、me-central-1阿联酋、sa-east-1圣保罗、cn-north-1北京、cn-northwest-1宁夏选择时需保证该区域与 Topic 的实际创建区域一致否则ListTopics与Publish将无法命中目标。Endpoint 字段本地/自定义端点调试入口endpoint为可选字段。从 common.ts 的实现可以看到它对空值与nil做了特殊处理endpoint: auth.endpoint || isNil(auth.endpoint) ? undefined : auth.endpoint,即留空时不会传给 AWS SDK客户端使用标准的 AWS 区域端点填入值时则将其作为SNSClient的显式端点。这个字段的实际价值在于对接 SNS 兼容的第三方实现或本地模拟服务如 LocalStack 类的 SNS 端点做联调测试。对正常使用云上 SNS 的用户官方说明明确要求留空。凭证校验连接时自动验证CustomAuth还定义了一个validate钩子index.ts保存/测试连接时它用当前凭证构造SNSClient并发送ListTopicsCommand若成功返回{ valid: true }失败则返回{ valid: false, error: message }把 AWS 返回的错误原文如权限不足、密钥错误、Region 不匹配直接暴露给用户。这意味着凭证错误在配置阶段就会被拦截而不是等到流程运行时才报错。Send Message 动作字段与行为动作定义位于 send-message.ts它只有两个输入属性属性组件类型必填说明topicProperty.Dropdown是目标主题 ARN运行时动态加载messageProperty.LongText是消息正文支持多行文本与表达式变量Topic 下拉运行时通过 ListTopics 动态加载topic是动态下拉它在动作渲染时调用 AWSListTopicsCommand拉取当前账号/Region 下全部主题label取 ARN 的最后一个冒号片段即主题名value存完整 ARN。该下拉对auth设置了refreshers: [auth]凭证变化时会自动重新加载选项未认证时返回disabled状态并提示 Please authenticate first无主题时提示 No topics found。需要留意的是下拉列表可能分页或数量较多且依赖sns:ListTopics权限如果 IAM 策略只授予了sns:Publish可以手动在流程变量中填入 ARN 使用构建时以代码为准。发送逻辑一次 PublishCommand 调用run方法的实现非常简洁核心只有两步const { topic, message } context.propsValue; const sns createSNS(context.auth.props); const response await sns.send(new PublishCommand({ TopicArn: topic, Message: message })); return response;它基于 AWS SDKaws-sdk/client-sns仓库锁定版本3.726.1见 package.json构造PublishCommand并直接返回 AWS 的响应对象包含MessageId等字段。从源码可以明确两点行为特征非幂等该动作的aiMetadata明确标注idempotent: false每次执行都会发布一条全新消息并再次投递给所有订阅端因此不适合用在可能重复触发的场景做「只发一次」的语义保证透传返回PublishCommand的响应会作为动作输出暴露给后续步骤流程中可以引用MessageId做日志关联或结果判断。底层原理createSNS 与 AWS SDK 客户端构造所有 AWS 调用都收敛到 common.ts 中的createSNS工厂函数export function createSNS(auth: { accessKeyId: string; secretAccessKey: string; region: string | undefined; endpoint: string | undefined; }) { const sns new SNSClient({ credentials: { accessKeyId: auth.accessKeyId, secretAccessKey: auth.secretAccessKey, }, region: auth.region, endpoint: auth.endpoint || isNil(auth.endpoint) ? undefined : auth.endpoint, }); return sns; }它把 Activepieces 的认证结构映射为SNSClient的credentials、region、endpoint三项配置。由于整个 Piece 只有这一个动作createSNS同时被三处复用认证validate校验、Topic 下拉加载、消息发送保证三处使用完全一致的客户端配置。从源码结构看后续若要扩展该 Piece例如增加CreateTopic、Subscribe等动作或 SNS 触发器只需要新增动作文件并沿用createSNS即可无需改动认证层。构建与本地验证README 中的构建命令原 README 的核心内容即构建方式使用 Turbo 以包过滤器构建该 Piece 库。turbo run build --filteractivepieces/piece-amazon-sns该命令在仓库根目录执行会触发 package.json 中定义的构建脚本build: tsc -p tsconfig.lib.json cp package.json dist/即先用tsc按tsconfig.lib.json编译 TypeScript 到dist/再把package.json拷贝进产物目录以保证发布包完整。除build外该包还提供turbo run lint --filteractivepieces/piece-amazon-sns # eslint 校验 src/**/*.ts bun run bundle # 通过 CLI 打包 piecepackage.json 中的 bundle 脚本bundle脚本内部调用 Activepieces CLI 的pieces bundle命令将 Piece 打包为可被运行时按需解析的产物。依赖方面该包只引入aws-sdk/client-sns3.726.1以及工作区内部的pieces-common、pieces-framework、core-piece-types、core-utils其余依赖如tslib仅用于开发构建保持了很轻的运行时体积。本地化与包信息该 Piece 的界面文案认证字段、Region 名称、动作显示名、提示语都做了 i18n 支持语言文件位于 src/i18n覆盖中文zh.json、德文、西班牙文、法文、日文、荷兰文、葡萄牙文、俄文、越南文等translation.json为英文默认文案。例如中文语言包中 Send Message 等字段键与默认文案一一对应说明该 Piece 的 UI 字符串全部经过翻译键提取流程。从 package.json 可以看到当前包版本为0.1.7属于workspace:*管理的 monorepo 子包结合 Piece 定义中minimumSupportedRelease: 0.36.1可以推断该 Piece 要求 Activepieces 运行时不低于 0.36.1 版本才能正常加载。使用注意事项与最佳实践结合源码行为汇总几条实战建议Region 必须与 Topic 一致Region 下拉有 31 个选项且有默认值us-east-1若 Topic 建在其他区域记得显式切换否则下拉加载不到目标主题。IAM 权限最小化至少需要sns:Publish发送与sns:ListTopics下拉加载 连接校验只读业务可再收紧为指定 Topic ARN 的资源级策略。连接测试先行保存连接时validate会真实调用 AWSListTopics趁此机会确认密钥与网络可达性避免把错误带到流程运行期。注意非幂等语义Publish每次执行都会投递一次涉及告警去重、消息上限等需求时应在流程层自行控制触发频率。利用返回的 MessageIdPublishCommand响应会透传给后续步骤可将其写入日志或作为审计依据。本地联调可填 Endpoint对接 SNS 兼容模拟器时填入对应端点云端使用则保持留空。小结activepieces/piece-amazon-sns是一个「小而精」的集成一个CustomAuth凭证结构、一个send-message动作、一个复用的SNSClient工厂即可把 AWS SNS 发布能力接入 Activepieces 的流程编排与 AI Agent 工具生态。本文从 README 的构建命令出发完整梳理了认证四字段Access Key ID、Secret Access Key、Region、Endpoint、动态 Topic 下拉、PublishCommand调用链与构建打包流程。需要扩展能力如订阅管理、主题创建、SNS 触发器的开发者可以以 src/lib/actions/send-message.ts 为模板新增动作并复用 src/lib/common.ts 的createSNS工厂保持与现有实现一致的风格与可靠性。【免费下载链接】activepiecesAI Agents MCPs AI Workflow Automation • (~400 MCP servers for AI agents) • AI Automation / AI Agent with MCPs • AI Workflows AI Agents • MCPs for AI Agents项目地址: https://gitcode.com/GitHub_Trending/ac/activepieces创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考