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

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

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

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

选择Amazon CloudFormation您的区域的模板

启动适当的Amazon CloudFormation堆叠在Amazon CloudFormation选择控制台,选择其中一个启动堆栈取决于下表中的按钮,具体取决于Amazon要使用的区域。

区域 查看 在 Designer 中查看 启动
美国东部(弗吉尼亚北部) 查看 在 Designer 中查看
美国东部(俄亥俄) 查看 在 Designer 中查看
美国西部(加利福尼亚北部) 查看 在 Designer 中查看
美国西部(俄勒冈) 查看 在 Designer 中查看
加拿大(中部) 查看 在 Designer 中查看
南美洲(圣保罗) 查看 在 Designer 中查看
欧洲(斯德哥尔摩) 查看 在 Designer 中查看
欧洲(爱尔兰) 查看 在 Designer 中查看
欧洲(伦敦) 查看 在 Designer 中查看
欧洲(巴黎) 查看 在 Designer 中查看
欧洲(法兰克福) 查看 在 Designer 中查看
中东(巴林) 查看 在 Designer 中查看
非洲(开普敦) 查看 在 Designer 中查看
亚太地区(东京) 查看 在 Designer 中查看
亚太地区(香港) 查看 在 Designer 中查看
亚太地区(首尔) 查看 在 Designer 中查看
亚太地区(新加坡) 查看 在 Designer 中查看
亚太地区(悉尼) 查看 在 Designer 中查看
亚太地区(孟买) 查看 在 Designer 中查看
中国(北京) 查看 在 Designer 中查看
中国(宁夏) 查看 在 Designer 中查看
Amazon GovCloud (美国西部) 查看 在 Designer 中查看
Amazon GovCloud (美国东部) 查看 在 Designer 中查看

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

添加详细信息关于你正在创建的 Neptune 直播消费者堆栈

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

Stack Name— 新的名称Amazon CloudFormation您正在创建的堆栈。通常可以使用默认值 NeptuneStreamPoller

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

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

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

  • SubnetIDs— 建立网络接口的子网。添加与 Neptune 集群对应的子网。

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

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

  • CreateDDBVPCEndPoint— 默认为的布尔值true,指示是否有必要创建 Dynamo DB VPC 终端节点。您只需将其更改为false如果您已在 VPC 中创建 DynamoDB 终端节点。

  • CreateMonitoringEndPoint— 默认为的布尔值true,表示是否有必要创建监控 VPC 终端节点。如果您已在 VPC 中创建镜像终端节点,则只需将其更改为 false

流轮询器

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

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

  • LambdaRuntime— Lambda 函数使用的语言,用于从 Neptune 流中检索项目。你可以将其设置为python3.6或者去java8.

  • LambdaS3Bucket— 包含 Lambda 代码构件的 Amazon S3 存储桶。除非您使用从其他 Amazon S3 存储桶加载的自定义 Lambda 轮询函数,否则将此设置保留为空。

  • LambdaS3Key— 与您的 Lambda 代码工件对应的 Amazon S3 密钥。除非您使用自定义 Lambda 轮询函数,否则将此设置保留为空。

  • LambdaLoggingLevel— 通常,将此设置保留为默认值,即INFO.

  • ManagedPolicies— 列出用于执行 Lambda 函数的托管策略。通常,除非您使用自定义 Lambda 轮询函数,否则将此设置保留为空。

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

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

  • MaxPollingWaitTime— 两次民意调查之间的最长等待时间(以秒为单位)。确定调用 Lambda 轮询器轮询 Neptune 流的频率。将此值设置为 0 以进行连续轮询。最大值为 3600 秒(1 小时)。默认值(60 秒)是一个很好的开始,具体取决于图形数据更改的速度。

  • MaxPollingInterval— 最长连续轮询周期(以秒为单位)。使用此设置 Lambda 轮询函数的超时。该值应该在 5 秒到 900 秒之间。默认值(600 秒)是一个很好的开始。

  • StepFunctionFallbackPeriod— 的单位数 step-function-fallback-period 等待轮询器,之后将通过 Amazon 调用步进函数 CloudWatch 要从故障中恢复的事件。默认值(5 分钟)是一个很好的开始。

  • StepFunctionFallbackPeriodUnit— 用于测量上述的时间单位StepFunctionFallbackPeriodUnit(minuteshours,或者days)。默认为 (minutes)通常就足够了。

Neptune 直播

  • NeptuneStreamEndpoint— (必需) Neptune 源流的终端节点。这采用以下两种形式:

    • https://your DB cluster:port/propertygraph/stream(或者它的别名,https://your DB cluster:port/pg/stream)。

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

  • Neptune Query Engine— 选择 Gremlin、openPher 或 SPARQL。

  • IAMAuthEnabledOnSourceStream— 如果 Neptune 数据库集群使用 IAM 身份验证,请将此参数设置为true.

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

目标 Neptune 数据库集群

  • TargetNeptuneClusterEndpoint— 目标备份群集的群集终端节点(仅限主机名)。

  • TargetNeptuneClusterPort— 目标集群的端口号。

  • IAMAuthEnabledOnTargetCluster— 如果要在目标群集上启用 IAM 身份验证,请设置为 true。

  • TargetAWSRegion— 目标备份群集的Amazon地区,例如us-east-1)。只有在Amazon目标备份群集的区域与 Neptune 源群集的区域不同,例如跨区域复制的情况。如果源区域和目标区域相同,则此参数是可选的。

    请注意,如果TargetAWSRegion价值不是有效AmazonNeptune 支持的地区,该过程失败。

  • TargetNeptuneDBClusterResourceId— 目标集群的资源 ID。

警报

  • 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_neptune.json
  5. Select下一步没有更改任何Amazon CloudFormation参数。

  6. 选择 Update Stack

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