在 Amazon SNS 中发布消息 - Amazon SDK for JavaScript
情景先决条件任务将消息发布到 SNS 主题
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon SDK for JavaScript V3 API 参考指南详细描述了 Amazon SDK for JavaScript 版本 3 (V3) 的所有 API 操作。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

在 Amazon SNS 中发布消息

JavaScript code example that applies to Node.js execution

此 Node.js 代码示例演示：

  • 如何将消息发布到 Amazon SNS 主题。

情景

在本示例中，您使用一系列 Node.js 模块，将消息从 Amazon SNS 发布到主题端点、电子邮件或电话号码。Node.js 模块使用 SDK for JavaScript，通过 SNS 客户端类的以下方法发送消息：

先决条件任务

要设置和运行此示例，您必须先完成以下任务：

  • 设置项目环境以运行这些 Node TypeScript 示例，并安装所需的 Amazon SDK for JavaScript 和第三方模块。请按照 GitHub 上的说明进行操作。

  • 使用用户凭证创建共享配置文件。有关提供共享凭证文件的更多信息，请参阅《Amazon SDK 和工具参考指南》 中的共享配置和凭证文件。

重要

这些示例演示了如何使用 ECMAScript6 (ES6) 导入/导出客户端服务对象和命令。

将消息发布到 SNS 主题

在本示例中，使用 Node.js 模块将消息发布到 Amazon SNS 主题。

创建一个 libs 目录，然后使用文件名 snsClient.js 创建一个 Node.js 模块。将以下代码复制并粘贴到其中，这将创建 Amazon SNS 客户端对象。将 REGION 替换为您的 Amazon 区域。

import { SNSClient } from "@aws-sdk/client-sns";

// The AWS Region can be provided here using the `region` property. If you leave it blank
// the SDK will default to the region set in your AWS config.
export const snsClient = new SNSClient({});

此示例代码可在 GitHub 上的此处找到。

创建文件名为 publish-topic.js 的 Node.js 模块。按前面所示配置 SDK。

创建包含用于发布消息的参数的对象，包括消息文本以及 Amazon SNS 主题的 Amazon 资源名称 (ARN)。有关可用 SMS 属性的详细信息，请参阅SetSMSAttributes。

将参数传递到 SNS 客户端类的 PublishCommand 方法。创建一个异步函数，调用 Amazon SNS 客户端服务对象并传递参数对象。

注意

将 MESSAGE_TEXT 替换为消息文本，将 TOPIC_ARN 替换为 SNS 主题的 ARN。

import { PublishCommand } from "@aws-sdk/client-sns";
import { snsClient } from "../libs/snsClient.js";

/**
 * @param {string | Record<string, any>} message - The message to send. Can be a plain string or an object
 *                                                 if you are using the `json` `MessageStructure`.
 * @param {string} topicArn - The ARN of the topic to which you would like to publish.
 */
export const publish = async (
  message = "Hello from SNS!",
  topicArn = "TOPIC_ARN",
) => {
  const response = await snsClient.send(
    new PublishCommand({
      Message: message,
      TopicArn: topicArn,
    }),
  );
  console.log(response);
  // {
  //   '$metadata': {
  //     httpStatusCode: 200,
  //     requestId: 'e7f77526-e295-5325-9ee4-281a43ad1f05',
  //     extendedRequestId: undefined,
  //     cfId: undefined,
  //     attempts: 1,
  //     totalRetryDelay: 0
  //   },
  //   MessageId: 'xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx'
  // }
  return response;
};

要运行示例，请在命令提示符中键入以下内容。

node publish-topic.js

此示例代码可在 GitHub 上的此处找到。