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.
# Neptune-to-OpenSearchReplicación de Amazon
Amazon Neptune admite la búsqueda de texto completo en las consultas de Gremlin y SPARQL mediante Amazon Service (Servicio). OpenSearch OpenSearch Puede usar una AWS CloudFormation pila para vincular un dominio OpenSearch de servicio a Neptune. La CloudFormation plantilla crea una instancia de aplicación para consumidores de transmisiones que proporciona replicación. Neptune-to-OpenSearch
Antes de empezar, necesita un clúster de base de datos de Neptune existente con transmisiones habilitadas para que sirva como origen y un dominio de OpenSearch servicio que sirva como destino de la replicación.
Si ya tiene un dominio de OpenSearch servicio de destino al que Lambda pueda acceder en la VPC en la que se encuentra el clúster de base de datos de Neptune, la plantilla puede usarlo. De lo contrario, es necesario crear una nueva.
**nota**
El OpenSearch clúster y la función Lambda que cree deben estar ubicados en la misma VPC que el clúster de base de datos de Neptune, y el clúster OpenSearch debe estar configurado en modo VPC (no en modo Internet).
Le recomendamos que utilice una instancia de Neptune recién creada para usarla con OpenSearch Service. Si utilizas una instancia existente que ya contiene datos, debes realizar una sincronización de datos del OpenSearch Servicio antes de realizar consultas o podría haber inconsistencias en los datos. Este GitHub proyecto proporciona un ejemplo de cómo realizar la sincronización: [Exportar Neptuno a OpenSearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) (https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch).
**importante**
Al integrarse con Amazon OpenSearch Service, Neptune requiere la versión 7.1 o superior de Elasticsearch y funciona con las versiones OpenSearch 2.3, 2.5 y futuras de Opensearch compatibles.
**nota**
A partir de la [versión 1.3.0.0 del motor](engine-releases-1.3.0.0.md), Amazon Neptune admite el uso de [ OpenSearch Amazon Service](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless.html) Serverless para la búsqueda de texto completo en consultas de Gremlin y SPARQL.
**Topics**
+ [Uso de AWS CloudFormation una plantilla para iniciar la replicación Neptune-to-OpenSearch](full-text-search-cfn-create.md)
+ [Habilitar la búsqueda de texto completo en las bases de datos de Neptune existentes](full-text-search-cfn-enabling.md)
+ [Actualización del sondeador de flujos](full-text-search-cfn-update-poller.md)
+ [Habilitación y nueva habilitación del proceso del sondeador de flujos](full-text-search-using-pausing-poller.md)
# Uso de AWS CloudFormation una plantilla para iniciar la replicación Neptune-to-OpenSearch
## Lanza una CloudFormation pila específica para tu región
Cada una de las CloudFormation plantillas siguientes crea una instancia de aplicación streams-consumer en una región específica AWS . Para lanzar la pila correspondiente mediante la CloudFormation consola, selecciona uno de los botones de **lanzar la pila** de la siguiente tabla, en función de la AWS región que quieras usar.
| Region | Visualización | Ver en Designer | Lanzar |
| --- | --- | --- | --- |
| Este de EE. UU. (Norte de Virginia) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=us-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Este de EE. UU. (Ohio) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=us-east-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-east-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-east-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Oeste de EE. UU. (Norte de California) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Oeste de EE. UU. (Oregón) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Canadá (centro) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ca-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ca-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| América del Sur (São Paulo) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=sa-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=sa-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=sa-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (Estocolmo) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-north-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (Irlanda) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (Londres) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (París) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-3&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (España) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-south-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-south-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-south-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Europa (Fráncfort) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Middle East (Bahrain) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=me-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=me-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=me-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Medio Oriente (EAU) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=me-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=me-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=me-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Israel (Tel Aviv) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=il-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=il-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=il-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| África (Ciudad del Cabo) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=af-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=af-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=af-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Hong Kong) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Tokio) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-northeast-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Seúl) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-northeast-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Singapur) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-southeast-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Yakarta) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-southeast-3&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| Asia-Pacífico (Mumbai) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| China (Pekín) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.amazonaws.cn/cloudformation/designer/home?region=cn-north-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws.cn/cloudformation/home?region=cn-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws.cn/cloudformation/home?region=cn-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| China (Ningxia) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.amazonaws.cn/cloudformation/designer/home?region=cn-northwest-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws.cn/cloudformation/home?region=cn-northwest-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws.cn/cloudformation/home?region=cn-northwest-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| AWS GovCloud (EE. UU.-Oeste) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.amazonaws-us-gov.com/cloudformation/designer/home?region=us-gov-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
| AWS GovCloud (Estados Unidos-Este) | [Ver](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Ver en Designer](https://console.amazonaws-us-gov.com/cloudformation/designer/home?region=us-gov-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) |
En la página **Create Stack (Crear pila)**, elija **Next (Siguiente)**.
## Agrega detalles sobre la nueva OpenSearch pila que estás creando
En la página **Especificar los detalles de la pila**, se proporcionan las propiedades y los parámetros que puede utilizar para controlar la configuración de la búsqueda de texto completo:
**Nombre de la pila**: el nombre de la nueva 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 la VPC en la que se ejecuta el consumidor de flujos**
+ **`VPC`**: proporcione el nombre de la VPC en la que se ejecutará la función de Lambda de sondeo.
+ **`List of Subnet IDs`**: las subredes en las que se establece una interfaz de red. Añada las subredes correspondientes a su clúster de Neptune.
+ **`List of Security Group Ids`**— Proporcione los grupos IDs de seguridad que otorgan acceso de escritura entrante a su clúster de base de datos Neptune de origen.
+ **`List of Route Table Ids`**: 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.
+ **`Require to create Dynamo DB VPC Endpoint`**: un valor booleano que, de forma predeterminada, es `true`. Solo necesita cambiarlo por `false` si ya ha creado un punto de conexión de DynamoDB en su VPC.
+ **`Require to create Monitoring VPC Endpoint`**: un valor booleano que, de forma predeterminada, es `true`. Solo necesita cambiarlo por `false` si ya ha creado un punto de enlace de monitorización en su VPC.
**Sondeador de flujo**
+ **`Application Name`**: por lo general, puede dejar esta opción con el valor predeterminado (`NeptuneStream`). Si utiliza un nombre diferente, debe ser único.
+ **`Memory size for Lambda Poller`**: se utiliza para establecer el tamaño de memoria disponible para la función de sondeo de Lambda. El valor predeterminado es 2048 megabytes.
+ **`Lambda Runtime`**: el lenguaje utilizado en la función de Lambda que recupera elementos del flujo de Neptune. Puede configurarlo en `python3.9` o en `java8`.
+ **`S3 Bucket having Lambda code artifacts`**: deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada que se cargue desde un bucket de S3 diferente.
+ **`S3 Key corresponding to Lambda Code artifacts`**: deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada.
+ **`StartingCheckpoint`**: el punto de control inicial del sondeador de flujos. 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.
+ **`Logging level for Lambda`**: en general, deje esta opción con el valor predeterminado, `INFO`.
+ **`Managed Policies for Lambda Execution`**: en general, deje este campo en blanco a menos que utilice una función de sondeo de Lambda personalizada.
+ **`Stream Records Handler`**: en general, deje este campo en blanco a menos que utilice un controlador personalizado para los registros en los flujos de Neptune.
+ **`Maximum records Fetched from Stream`**: puede utilizar este parámetro para ajustar el rendimiento. El valor predeterminado (`100`) 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.
+ **`Max wait time between two Polls (in Seconds)`**: determina la frecuencia con la que se invoca el sondeador de 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.
+ **`Maximum Continuous polling period (in Seconds)`**: se utiliza para establecer un tiempo de espera para la función de sondeo de Lambda. Debería estar entre 5 segundos y 900 segundos. El valor predeterminado (600 segundos) es un buen lugar para empezar.
+ **`Step Function Fallback Period`**— El número de step-function-fallback-period unidades que esperarán 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.
+ **`Step Function Fallback Period Unit`**: las unidades de tiempo utilizadas para medir el `Step Function Fallback Period` anterior (minutos, horas, días). El valor predeterminado generalmente es suficiente (minutos).
+ **`Enable/disable creation of Elastic Search Mappings by Lambda`**— Marcar la gestión enable/disable automática de los mapeos de Elastic Search por parte del encuestador de flujos. Los mapeos de Elastic Search son fundamentales para la conversión entre los tipos de datos de Neptune y Elastic Search. Esto solo lo deben deshabilitar los usuarios avanzados que deseen asumir el control directo y manual de todos los mapeos de su índice de Elastic Search. El valor predeterminado es `true`.
+ **`Data replication scope`**— Determina si se deben replicar tanto los nodos como los bordes, o solo los nodos OpenSearch (esto se aplica únicamente a los datos del motor Gremlin). El valor predeterminado (All) es un buen lugar para empezar por lo general.
+ **`Ignore OpenSearch missing document error`**— Marca para determinar si se OpenSearch puede ignorar un error en un documento faltante. Los errores de falta de documentos se producen en raras ocasiones, pero necesitan intervención manual si no se ignoran. El valor predeterminado (`True`) suele ser un buen lugar para empezar.
+ **`Enable Non-String Indexing`**: indicador para habilitar o deshabilitar la indexación de campos que no tienen contenido de cadena. Si este indicador está establecido en `true` OpenSearch, los campos que no son cadenas se indexan o si `false` solo se indexan los campos de cadena. El valor predeterminado es `true`.
+ **`Properties to exclude from being inserted into OpenSearch`**— Una lista delimitada por comas de claves de propiedades o predicados para excluirlas de la indexación. OpenSearch Si el valor de este parámetro de CFN se deja en blanco, se indexan todas las claves de propiedad.
+ **`Datatypes to exclude from being inserted into OpenSearch`**— Una lista delimitada por comas de tipos de datos de propiedades o predicados para excluirlos de la indexación. OpenSearch Si el valor de este parámetro CFN se deja en blanco, se indexan todos los valores de propiedad que se puedan convertir de forma segura en tipos de datos. OpenSearch
**Flujo de Neptune**
+ **`Endpoint of source Neptune Stream`**: (*obligatorio*) 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`**: elija Gremlin o SPARQL.
+ **`Is IAM Auth Enabled?`**: si su clúster de base de datos de Neptune usa la autenticación de IAM, establezca este parámetro como `true`.
+ **`Neptune Cluster Resource Id`**: 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.
**Clúster de destino OpenSearch**
+ **`Endpoint for OpenSearch service`**— (Obligatorio) Proporcione el punto final del OpenSearch servicio en su VPC.
+ **`Number of Shards for OpenSearch Index`**: el valor predeterminado (5) suele ser un buen lugar para empezar.
+ **`Number of Replicas for OpenSearch Index`**: el valor predeterminado (1) suele ser un buen lugar para empezar.
+ **`Geo Location Fields for Mapping`**: si utiliza campos de geolocalización, enumere las claves de propiedad aquí.
**Alarma**
+ **`Require to create Cloud watch Alarm`**— Configúrelo en `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).
Como destino de la notificación de alarma, puede añadir solo SNS, solo correo electrónico o tanto SNS como correo electrónico.
## Ejecute la plantilla CloudFormation
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 CloudFormation, en la página **Especificar los detalles de la pila**, elija **Siguiente**.
1. En la página **Opciones**, seleccione **Siguiente**.
1. En la página **Revisar**, seleccione la primera casilla para confirmar que CloudFormation debe crear los recursos de IAM. 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 el funcionamiento de la CloudFormation [CreateStack](https://docs.aws.amazon.com/AWSCloudFormation/latest/APIReference/API_CreateStack.html)API en la *referencia de la AWS CloudFormation API*.
A continuación, seleccione **Crear**.
# Habilitar la búsqueda de texto completo en las bases de datos de Neptune existentes
Estos son los enfoques establecidos para habilitar la búsqueda de texto completo en bases de datos de Amazon Neptune existentes. Los pasos pueden variar ligeramente en función de si puede o no pausar las cargas de trabajo de escritura. En esta guía se describen los pasos recomendados para ambos escenarios: cuando pueda pausar la escritura y cuando no pueda hacerlo. Abarca la activación de las transmisiones de Neptune, la creación de un clon de base de datos, la sincronización de datos con un OpenSearch dominio y la configuración de actualizaciones continuas. La guía aprovecha los AWS servicios y las herramientas de código abierto para agilizar el proceso y minimizar el tiempo de inactividad.
## Si puede pausar sus cargas de trabajo de escritura
La mejor forma de habilitar la búsqueda de texto completo en una base de datos de Neptune existente suele ser la siguiente, siempre que pueda pausar las cargas de trabajo de escritura. Para ello, es necesario crear un clon, habilitar los flujos mediante un parámetro de clúster y reiniciar todas las instancias. La creación de un clon es una operación relativamente rápida, por lo que el tiempo de inactividad necesario es limitado.
Estos son los pasos necesarios:
1. Detenga todas las cargas de trabajo de escritura en la base de datos.
1. Habilite los flujos en la base de datos (consulte [Enabling Neptune Streams](streams-using-enabling.md)).
1. Cree un clon de la base de datos (consulte [Database Cloning in Neptune](manage-console-cloning.md)).
1. Reanude las cargas de trabajo de escritura.
1. Usa la [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)herramienta en github para realizar una sincronización única de la base de datos clonada al dominio. OpenSearch
1. Use la [plantilla de CloudFormation de su región](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region) para iniciar la sincronización desde su base de datos original con una actualización continua (no es necesario cambiar la configuración de la plantilla).
1. Elimina la base de datos clonada y la CloudFormation pila creada para la `export-neptune-to-elasticsearch` herramienta.
**nota**
Si se utiliza [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)con Opensearch Serverless, los datos `LambdaExecutionRole` creados por la pila de [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)Cloudformation deben añadirse a la [política de acceso a los datos de Opensearch](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless-data-access.html) para poder replicarlos correctamente.
## Si no puede pausar sus cargas de trabajo de escritura
Si no puede permitirse suspender las cargas de trabajo de escritura en su base de datos, aquí tiene un enfoque que requiere incluso menos tiempo de inactividad que el enfoque recomendado anteriormente, pero debe hacerse con cuidado:
1. Habilite los flujos en la base de datos (consulte [Enabling Neptune Streams](streams-using-enabling.md)).
1. Cree un clon de la base de datos (consulte [Database Cloning in Neptune](manage-console-cloning.md)).
1. Obtenga el último `eventID` de los flujos de la base de datos clonada mediante la ejecución de un comando de este tipo en el punto de conexión de la API de flujos (consulte [Calling the Neptune Streams REST API](streams-using-api-call.md) para obtener más información):
```
curl "https://(your neptune endpoint):(port)/(propertygraph or sparql)/stream?iteratorType=LATEST"
```
Anote los valores de los campos `commitNum` y `opNum` del objeto `lastEventId` en la respuesta.
1. Usa la [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)herramienta en GitHub para realizar una sincronización única entre la base de datos clonada y el dominio. OpenSearch
1. Use la [plantilla de CloudFormation de su región](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region) para iniciar la sincronización desde su base de datos original con una actualización continua.
Realiza el siguiente cambio al crear la pila: en la página de detalles de la pila, en la sección **Parámetros**, establece el valor del `StartingCheckpoint` campo en**commitNum**: **opnum** usando los `opNum` valores `commitNum` y que registraste anteriormente.
1. Elimine la base de datos clonada y la CloudFormation pila creada para la `export-neptune-to-elasticsearch` herramienta.
# Actualización del sondeador de flujos
La siguiente información describe los pasos necesarios para actualizar el sondeador de transmisiones con los artefactos Lambda más recientes mediante AWS la consola de administración.
## 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 Consola de administración de AWS, navegue hasta la pila principal principal CloudFormation CloudFormation y selecciónela.
1. Seleccione la opción **Actualizar** para la pila.
1. Seleccione **Reemplazar la plantilla actual**.
1. Para la fuente de la plantilla, elija la **URL de Amazon S3** e introduzca la siguiente URL de S3:
```
https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json
```
1. Seleccione **Siguiente** sin cambiar ningún CloudFormation parámetro.
1. Elija **Update Stack (Actualizar pilar)**.
La pila actualizará ahora los artefactos de Lambda con los más recientes.
## Ampliación del sondeador de flujos para admitir campos personalizados
El sondeador de flujos actual se puede ampliar fácilmente para escribir código personalizado para gestionar campos personalizados, como se explica en detalle en esta entrada del blog: [Capture graph changes using Neptune Streams](https://aws.amazon.com/blogs/database/capture-graph-changes-using-neptune-streams/).
**nota**
Al añadir un campo personalizado OpenSearch, asegúrese de añadir el nuevo campo como objeto interno de un predicado (consulte[Modelo de datos de búsqueda de texto completo de Neptune](full-text-search-model.md)).
# Habilitación y nueva habilitación del proceso del sondeador de flujos
**aviso**
Tenga cuidado al deshabilitar el proceso de sondeador de flujos. Se podrían perder datos si el proceso se detiene durante más tiempo que el período de caducidad del flujo. El período predeterminado es de 7 días, pero a partir de la versión [1.2.0.0](engine-releases-1.2.0.0.md) del motor, puede configurar un período de caducidad del flujo personalizado hasta un máximo de 90 días.
# Deshabilitación (pausa) del proceso del sondeador de flujos
1. Inicia sesión en la EventBridge consola de Amazon Consola de administración de AWS y ábrela en [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. En el panel de navegación, seleccione **Reglas**.
1. Selecciona la regla cuyo nombre contenga el nombre que proporcionaste como **nombre de la aplicación** en la CloudFormation plantilla que usaste para configurar Stream Poller.
1. Elija **Deshabilitar**.
1. Abra la consola Step Functions en [https://console.aws.amazon.com/states/](https://console.aws.amazon.com/states/).
1. Seleccione la función de paso en ejecución que corresponda al proceso del sondeador de flujos. De nuevo, el nombre de esa función de paso contiene el nombre que proporcionó como **nombre de la aplicación** en la CloudFormation plantilla que utilizó para configurar el sondeador de transmisiones. Puede filtrar por estado de ejecución de la función para ver solo las funciones **En ejecución**.
1. Elija **Detener**.
# Nueva habilitación del proceso del sondeador de flujos
1. Inicia sesión en la EventBridge consola de Amazon Consola de administración de AWS y ábrela en [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. En el panel de navegación, seleccione **Reglas**.
1. Selecciona la regla cuyo nombre contenga el nombre que proporcionaste como **nombre de la aplicación** en la CloudFormation plantilla que usaste para configurar Stream Poller.
1. Seleccione **Habilitar**. La regla de eventos basada en el intervalo programado especificado activará ahora una nueva ejecución de la función de paso.