使用Amazon CloudFormation使用流使用者应用程序设置 Neptune 到的复制 - Amazon Neptune
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

使用Amazon CloudFormation使用流使用者应用程序设置 Neptune 到的复制

您可以使用Amazon CloudFormation模板以设置 Neptune 流使用者应用程序以支持 Neptune 到 Neptune 的复制。

选择Amazon CloudFormation您的区域模板

要启动相应的Amazon CloudFormation堆栈上的Amazon CloudFormation控制台中,选择其中一个启动堆栈按钮,具体取决于Amazon您希望使用的区域。

区域 查看 在 Designer 中查看 启动
美国东部(弗吉尼亚北部) 查看 在 Designer 中查看
US East (Ohio) 查看 在 Designer 中查看
美国西部(加利福尼亚北部) 查看 在 Designer 中查看
美国西部(俄勒冈) 查看 在 Designer 中查看
加拿大(中部) 查看 在 Designer 中查看
南美洲(圣保罗) 查看 在 Designer 中查看
Europe (Stockholm) 查看 在 Designer 中查看
欧洲(爱尔兰) 查看 在 Designer 中查看
Europe (London) 查看 在 Designer 中查看
Europe (Paris) 查看 在 Designer 中查看
Europe (Frankfurt) 查看 在 Designer 中查看
Middle East (Bahrain) 查看 在 Designer 中查看
亚太区域(东京) 查看 在 Designer 中查看
Asia Pacific (Hong Kong) 查看 在 Designer 中查看
Asia Pacific (Seoul) 查看 在 Designer 中查看
亚太地区(新加坡) 查看 在 Designer 中查看
亚太地区(悉尼) 查看 在 Designer 中查看
Asia Pacific (Mumbai) 查看 在 Designer 中查看
China (Beijing) 查看 在 Designer 中查看
China (Ningxia) 查看 在 Designer 中查看
Amazon GovCloud (US-West) 查看 在 Designer 中查看
Amazon GovCloud (US-East) 查看 在 Designer 中查看

Create stack (创建堆栈) 主页上,选择 Next (下一步)

添加详细信息关于您正在创建的 Neptune 流消费者堆栈

Specify Stack Details (指定堆栈详细信息) 页面提供了属性和参数,可用于控制应用程序的设置。

Stack Name— 新Amazon CloudFormation堆栈。通常可以使用默认值 NeptuneStreamPoller

Parameters (参数) 下,提供以下内容:

流使用者运行的 VPC 的网络配置

  • VPC— 提供将运行轮询 Lambda 函数的 VPC 的名称。

  • List of Subnet IDs— 建立网络接口的子网。添加与您的 Neptune 集群对应的子网。

  • List of Security Group Ids— 提供向源 Neptune 数据库集群授予写入站访问权限的安全组的 ID。

  • List of Route Table Ids— 如果您还没有 Amazon DynamoDB 终端节点,则需要在您的 Neptune VPC 中创建 Amazon DynamoDB 终端节点。您必须提供与子网关联的路由表 ID 的逗号分隔列表。

  • Require to create Dynamo DB VPC Endpoint— 默认为的布尔值true. 只需将其更改为false如果您已在 VPC 中创建 DynamoDB 终端节点,请执行此操作。

  • Require to create Monitoring VPC Endpoint— 默认为的布尔值true. 如果您已在 VPC 中创建镜像终端节点,则只需将其更改为 false

流轮询器

  • Application Name— 您通常可以将此设置保留为默认值(NeptuneStream)。如果您使用不同的名称,则该名称必须是唯一的。

  • Memory size for Lambda Poller— 用于设置 Lambda 轮询器函数可用的内存大小。默认值为 2,048 MB。

  • Lambda Runtime— Lambda 函数用于从 Neptune 流中检索项目的语言。您可以将其设置为python3.6java8.

  • S3 Bucket having Lambda code artifacts— 除非您使用从其他 S3 存储桶加载的自定义 Lambda 轮询函数,否则将此设置保留为空。

  • S3 Key corresponding to Lambda Code artifacts— 除非您使用自定义 Lambda 轮询函数,否则将此设置保留为空。

  • Logging level for Lambda— 通常,将此设置保留为默认值,INFO.

  • Managed Policies for Lambda Execution— 通常,除非您使用自定义 Lambda 轮询函数,否则将此设置保留为空。

  • Stream Records Handler— 通常,除非您为 Neptune 流中的记录使用自定义处理程序,否则将此设置保留为空。

  • Maximum records Fetched from Stream— 您可以使用此参数来优化性能。默认值 (100) 是一个很好的开始。允许的最大值为 10,000。数字越大,从流读取记录所需的网络调用就越少,但处理记录所需的内存越多。此参数值越低会导致吞吐量降低。

  • Max wait time between two Polls (in Seconds)— 确定调用 Lambda 轮询器轮询 Neptune 流的频率。将此值设置为 0 以进行连续轮询。最大值为 3,600 秒(1 小时)。默认值(60 秒)是一个很好的开始,具体取决于图形数据更改的速度。

  • Maximum Continuous polling period (in Seconds)— 用于设置 Lambda 轮询函数的超时。它应该是 5 秒到 900 秒之间。默认值(600 秒)是一个很好的开始。

  • Step Function Fallback Period— 等待轮询器的步进函数回退时间单位数,之后将通过 Amazon CloudWatch Events 调用步进函数以从故障中恢复。默认值(5 分钟)是一个很好的开始。

  • Step Function Fallback Period Unit— 用于测量上述Step Function Fallback Period(分钟, 小时, 天). 默认值(分钟)通常就足够了。

  • Data replication scope— 确定是要复制节点和边缘,还是仅复制节点以进行弹性设置。OpenSearch(这仅适用于 Gemlin 发动机数据)。默认值(All (全部))通常是一个很好的开始。

  • Ignore Elastic Search missing document error— 用于确定是否在OpenSearch可以忽略。缺少文档错误很少发生,但如果不忽略,则需要手动干预。默认值 (True) 通常是一个很好的开始。

Neptune Neptune Neptune

  • Endpoint of source Neptune Stream— (必需)它采用以下两种形式之一:

    • https://your DB cluster:port/gremlin/stream

    • https://your DB cluster:port/sparql/stream

  • Neptune Query Engine— 选择 Gremlin 或 SPARQL。

  • Is IAM Auth Enabled?— 如果您的 Neptune DB 集群使用 IAM 身份验证,请将此参数设置为true.

  • Neptune Cluster Resource Id— 如果您的 Neptune DB 集群使用 IAM 身份验证,请将此参数设置为集群资源 ID。资源 ID 与集群 ID 不同。相反,它采取的形式:cluster-后跟 28 个字母数字字符。它可以在群集详细信息在 Neptune 控制台中。

Alarm

  • Required to create Cloud watch Alarm— 将其设置为true如果要为新堆栈创建 CloudWatch 警报,请执行弹出操作。

  • Email for Alarm Notifications— 应向其发送警报通知的电子邮件地址(仅在启用警报时才需要)。

运行 Amazon CloudFormation 模板

现在,您可以完成预配置 Neptune 流使用者应用程序实例的过程,如下所示:

  1. 在 Amazon CloudFormation 中的 Specify Stack Details (指定堆栈详细信息) 页面上,选择 Next (下一步)

  2. Options (选项) 页面上,选择 Next (下一步)

  3. 在存储库的审核页面上,选中第一个复选框以确认Amazon CloudFormation将创建 IAM 资源。选中第二个复选框以确认新堆栈的 CAPABILITY_AUTO_EXPAND

    注意

    CAPABILITY_AUTO_EXPAND 明确确认在创建堆栈时将扩展宏,而无需事先审核。用户通常通过处理的模板创建更改集,以便在实际创建堆栈之前对宏所做的更改进行审核。有关更多信息,请参阅 。Amazon CloudFormation CreateStack中的 APIAmazon CloudFormationAPI 参考.

    然后选择 Create (创建)

使用最新的 Lambda 工件更新流轮询器

您可以使用最新的 Lambda 代码工件更新流轮询器,如下所示:

  1. 在Amazon Web Services Management Console,导航到Amazon CloudFormation,然后选择主父项Amazon CloudFormation堆栈。

  2. 选择更新选项以进行堆栈。

  3. Select替换当前模板.

  4. 对于模板源,请选择Amazon S3 URL并输入以下 S3 URL:

    https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json
  5. Select下一步而不更改任何Amazon CloudFormation参数。

  6. 选择 Update Stack

堆栈现在将使用最新的 Lambda 工件更新。