Utilización AWS CloudFormation para configurar la Neptune-to-Neptune replicación con la aplicación Streams Consumer - Amazon Neptune

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Utilización AWS CloudFormation para configurar la Neptune-to-Neptune replicación con la aplicación Streams Consumer

Puede usar una AWS CloudFormation plantilla para configurar la aplicación de consumo Neptune Streams para admitir Neptune-to-Neptune la replicación.

Elija una AWS CloudFormation plantilla para su región

Para lanzar la AWS CloudFormation pila adecuada en la AWS CloudFormation consola, selecciona uno de los botones de lanzamiento de la siguiente tabla, en función de la AWS región que quieras usar.

Región Visualización Ver en Designer iniciar
Este de EE. UU. (Norte de Virginia) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Este de EE. UU. (Ohio) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Oeste de EE. UU. (Norte de California) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Oeste de EE. UU. (Oregón) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Canadá (centro) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
América del Sur (São Paulo) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Europa (Estocolmo) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Europa (Irlanda) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Europa (Londres) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Europa (París) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Europa (Fráncfort) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Medio Oriente (Baréin) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Oriente Medio (UAE) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Israel (Tel Aviv) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
África (Ciudad del Cabo) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia-Pacífico (Tokio) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia-Pacífico (Hong Kong) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia-Pacífico (Seúl) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia-Pacífico (Singapur) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia-Pacífico (Sídney) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
Asia Pacific (Bombay) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
China (Pekín) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
China (Ningxia) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
AWS GovCloud (Estados Unidos-Oeste) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.
AWS GovCloud (Estados Unidos-Este) Ver Ver en Designer Orange button labeled "Launch Stack" with an arrow icon.

En la página Create Stack (Crear pila), elija Next (Siguiente).

Añada detalles acerca de la pila del consumidor de flujos de Neptune que crea

La página Specify Stack Details (Especificar los detalles de la pila) proporciona las propiedades y los parámetros que puede utilizar para controlar la configuración de la aplicación:

Nombre de la pila: el nombre de la nueva AWS CloudFormation pila que está creando. Por lo general puede utilizar el valor predeterminado, NeptuneStreamPoller.

En Parámetros, proporcione lo siguiente:

Configuración de red para VPC Where the Streams Consumer
  • VPC— Indique el nombre del VPC lugar en el que se ejecutará la función Lambda de sondeo.

  • SubnetIDs: las subredes en las que se establece una interfaz de red. Añada las subredes correspondientes a su clúster de Neptune.

  • SecurityGroupIds— Proporcione los grupos IDs de seguridad que otorgan acceso de escritura entrante a su clúster de base de datos Neptune de origen.

  • RouteTableIds— Esto es necesario para crear un punto de conexión de Amazon DynamoDB en su VPC Neptune, si aún no tiene uno. Debe proporcionar una lista separada por comas de la tabla de rutas asociada a las subredes. IDs

  • CreateDDBVPCEndPoint— Un valor booleano que, por defectotrue, indica si es necesario o no crear un punto final de Dynamo DB. VPC Solo tiene que cambiarlo a false si ya ha creado un punto de conexión de DynamoDB en su. VPC

  • CreateMonitoringEndPoint— Un valor booleano cuyo valor predeterminado estrue, que indica si es necesario o no crear un punto final de supervisión. VPC Solo tiene que cambiarlo a false si ya ha creado un punto final de supervisión en su. VPC

Sondeador de flujo
  • ApplicationName: por lo general, puede dejar esta opción con el valor predeterminado (NeptuneStream). Si utiliza un nombre diferente, debe ser único.

  • LambdaMemorySize: se utiliza para establecer el tamaño de memoria disponible para la función de sondeo de Lambda. El valor predeterminado es 2048 megabytes.

  • LambdaRuntime: el lenguaje utilizado en la función de Lambda que recupera elementos del flujo de Neptune. Puede configurarlo en python3.9 o en java8.

  • LambdaS3Bucket: el bucket de Amazon S3 que contiene artefactos de código Lambda. Deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada que se cargue desde un bucket de Amazon S3 diferente.

  • LambdaS3Key: la clave de Amazon S3 que corresponde a sus artefactos de código Lambda. Deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada.

  • LambdaLoggingLevel: en general, deje esta opción con el valor predeterminado, que es INFO.

  • ManagedPolicies: muestra las políticas administradas que se van a utilizar para la ejecución de la función de Lambda. En general, deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada.

  • StreamRecordsHandler: en general, deje este campo en blanco a menos que utilice un controlador personalizado para los registros en los flujos de Neptune.

  • StreamRecordsBatchSize: el número máximo de registros que se recuperará del flujo. Puede utilizar este parámetro para ajustar el rendimiento. El valor predeterminado (5000) es un buen lugar para empezar. El valor máximo permitido es 10 000. Cuanto mayor sea el número, menos llamadas de red se necesitan para leer registros del flujo, pero más memoria se precisa para procesar los registros. Los valores más bajos de este parámetro dan como resultado un rendimiento inferior.

  • MaxPollingWaitTime: el tiempo máximo de espera entre dos sondeos (en segundos). Determina la frecuencia con la que se invoca el sondeador Lambda para sondear los flujos de Neptune. Establezca este valor en 0 para un sondeo continuo. El valor máximo es de 3600 segundos (1 hora). El valor predeterminado (60 segundos) es un buen lugar para empezar según la velocidad con la que cambien los datos del gráfico.

  • MaxPollingInterval: el período máximo de sondeo continuo (en segundos). Se utiliza para establecer un tiempo de espera para la función de sondeo de Lambda. El valor debe estar en el intervalo entre 5 y 900 segundos. El valor predeterminado (600 segundos) es un buen lugar para empezar.

  • StepFunctionFallbackPeriod— El número de unidades que deben esperar step-function-fallback-period al sondeador, tras lo cual se invoca la función step a través de Amazon CloudWatch Events para recuperarse de un fallo. El valor predeterminado (5 minutos) es un buen lugar para empezar.

  • StepFunctionFallbackPeriodUnit: las unidades de tiempo utilizadas para medir el StepFunctionFallbackPeriodUnit anterior (minutes, hours o days). El valor predeterminado (minutes) generalmente es suficiente.

Flujo de Neptune
  • NeptuneStreamEndpoint: (obligatorio) el punto de conexión del flujo de origen de Neptune. Adopta una de estas dos formas:

    • https://your DB cluster:port/propertygraph/stream (o su alias, https://your DB cluster:port/pg/stream).

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

  • Neptune Query Engine— Elige Gremlin, openCypher o. SPARQL

  • IAMAuthEnabledOnSourceStream— Si su clúster de base de datos de Neptune utiliza la IAM autenticación, defina este parámetro en. true

  • StreamDBClusterResourceId— Si su clúster de base de datos de Neptune utiliza la IAM autenticación, defina este parámetro en el ID de recurso del clúster. El ID del recurso no es el mismo que el ID del clúster. En su lugar, adopta el formato: cluster- seguido de 28 caracteres alfanuméricos. Se puede encontrar en Detalles del clúster en la consola de Neptune.

Clúster de base de datos Neptune de destino
  • TargetNeptuneClusterEndpoint: el punto de conexión del clúster (solo nombre de host) del clúster de copia de seguridad de destino.

    Tenga en cuenta que si especifica TargetNeptuneClusterEndpoint, no puede especificar también TargetSPARQLUpdateEndpoint.

  • TargetNeptuneClusterPort: el número de puerto del clúster de destino.

    Tenga en cuenta que si especifica TargetSPARQLUpdateEndpoint, se ignorará la configuración de TargetNeptuneClusterPort.

  • IAMAuthEnabledOnTargetCluster— Establézcalo en true si se va a habilitar la IAM autenticación en el clúster de destino.

  • TargetAWSRegion— La AWS región del clúster de respaldo de destino, por ejemplous-east-1). Debe proporcionar este parámetro solo cuando la AWS región del clúster de respaldo de destino sea diferente de la región del clúster de origen de Neptune, como en el caso de la replicación entre regiones. Si las regiones de origen y destino son las mismas, este parámetro es opcional.

    Tenga en cuenta que si el TargetAWSRegion valor no es una AWS región válida compatible con Neptune, el proceso fallará.

  • TargetNeptuneDBClusterResourceIdOpcional: esto solo es necesario cuando la IAM autenticación está habilitada en el clúster de base de datos de destino. Se establece en el identificador de recurso del clúster de destino.

  • SPARQLTripleOnlyMode: indicador booleano que determina si el modo solo triple está habilitado. En el modo de solo triple, no hay replicación de gráficos con nombre. El valor predeterminado es false.

  • TargetSPARQLUpdateEndpoint— URL del punto final de destino para su SPARQL actualización, por ejemplohttps://abc.com/xyz. Este punto final puede ser cualquier SPARQL tienda que soporte cuádruples o triples.

    Tenga en cuenta que si especifica TargetSPARQLUpdateEndpoint, no podrá especificar también TargetNeptuneClusterEndpoint y se omitirá la configuración de TargetNeptuneClusterPort.

  • BlockSparqlReplicationOnBlankNode — Indicador booleano que, si se establece entrue, detiene la replicación de los datos BlankNode in SPARQL (). RDF El valor predeterminado es false.

Alarma
  • Required to create Cloud watch Alarm— Configúrelo true si quiere crear una CloudWatch alarma para la nueva pila.

  • SNS Topic ARN for Cloudwatch Alarm Notifications— El SNS tema al que ARN se deben enviar las notificaciones de CloudWatch alarma (solo es necesario si las alarmas están activadas).

  • Email for Alarm Notifications: la dirección de correo electrónico a la que se deben enviar las notificaciones de alarma (solo es necesaria si las alarmas están activadas).

Como destino de la notificación de alarma, puede añadir SNS solo el correo electrónico o ambos SNS y el correo electrónico.

Ejecute la AWS CloudFormation plantilla

Ahora puede completar el proceso de aprovisionamiento de una instancia de aplicación de consumidor de flujos de Neptune de la siguiente manera:

  1. En AWS CloudFormation, en la página Especificar los detalles de la pila, elija Siguiente.

  2. En la página Opciones, seleccione Siguiente.

  3. En la página de revisión, active la primera casilla de verificación para confirmar que AWS CloudFormation se crearán IAM recursos. Seleccione la segunda casilla para confirmar CAPABILITY_AUTO_EXPAND para la nueva pila.

    nota

    CAPABILITY_AUTO_EXPAND confirma explícitamente que las macros se expandirán al crear la pila, sin revisión previa. Los usuarios suelen crear un conjunto de cambios a partir de una plantilla procesada para que los cambios realizados por las macros puedan revisarse antes de crear la pila. Para obtener más información, consulte AWS CloudFormation CreateStackAPIen la AWS CloudFormation APIReferencia.

    A continuación, seleccione Crear.

Para actualizar el sondeador de flujos con los artefactos de Lambda más recientes

Puede actualizar el sondeador de flujos con los artefactos de Lambda más recientes de la siguiente manera:

  1. En AWS Management Console, navegue hasta la AWS CloudFormation pila principal principal AWS CloudFormation y selecciónela.

  2. Seleccione la opción Actualizar para la pila.

  3. Seleccione Reemplazar la plantilla actual.

  4. Para la fuente de la plantilla, elija Amazon S3 URL e introduzca el siguiente S3URL:

    https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_neptune.json
  5. Seleccione Siguiente sin cambiar ningún AWS CloudFormation parámetro.

  6. Elija Update Stack (Actualizar pilar).

La pila actualizará ahora los artefactos de Lambda con los más recientes.