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

VPC: proporcione el nombre de la VPC en la que se ejecutará la función de 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 de Neptune, si todavía no dispone de uno. Debe proporcionar una lista separada por comas de la tabla de rutas IDs asociada a las subredes.

CreateDDBVPCEndPoint: valor booleano que es, de manera predeterminada, true, que indica si es necesario o no crear un punto de conexión de VPC de Dynamo DB. Solo necesita cambiarlo por false si ya ha creado un punto de conexión de DynamoDB en su VPC.

CreateMonitoringEndPoint: valor booleano que es, de manera predeterminada, true, que indica si es necesario o no crear un punto de conexión de VPC de monitorización. Solo necesita cambiarlo por false si ya ha creado un punto de enlace de monitorización en su VPC.

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.

StartingCheckpoint— El punto de control inicial del sondeador de arroyos. El valor predeterminado es 0:0, lo que significa comenzar desde el principio del flujo de Neptune.

StreamPollerInitialState— El estado inicial del sondeador. El valor predeterminado es ENABLED, lo que significa que la replicación del flujo se iniciará en cuanto se complete la creación de toda la pila.

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

Neptune Query Engine: elija Gremlin, openCypher o SPARQL.

IAMAuthEnabledOnSourceStream: si su clúster de base de datos de Neptune usa la autenticación de IAM, establezca este parámetro como true.

StreamDBClusterResourceId: si su clúster de base de datos de Neptune usa la autenticación de IAM, establezca este parámetro como el identificador de recurso de 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.

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 autenticación de IAM 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á.

TargetNeptuneDBClusterResourceId: opcional: esto solo es necesario cuando la autenticación de IAM 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 de conexión de destino para la actualización de SPARQL, como https://abc.com/xyz. Este punto de conexión puede ser cualquier almacén de SPARQL que admita 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 BlankNode en los datos de SPARQL (RDF). El valor predeterminado es false.

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 ARN del tema SNS al que CloudWatch se deben enviar las notificaciones de alarma (solo es necesario si las alarmas están habilitadas).

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).