Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
# Neptune-to-OpenSearchRéplication Amazon
Amazon Neptune prend en charge la recherche en texte intégral dans les requêtes Gremlin et SPARQL à l'aide d' OpenSearch Amazon Service (Service). OpenSearch Vous pouvez utiliser une AWS CloudFormation pile pour lier un domaine OpenSearch de service à Neptune. Le CloudFormation modèle crée une instance d'application streams-consumer qui assure Neptune-to-OpenSearch la réplication.
Avant de commencer, vous avez besoin d'un cluster de base de données Neptune existant sur lequel les flux sont activés pour servir de source, et d'un domaine de OpenSearch service pour servir de cible de réplication.
Si vous disposez déjà d'un domaine de OpenSearch service cible accessible par Lambda dans le VPC où se trouve votre cluster de base de données Neptune, le modèle peut utiliser celui-ci. Sinon, vous devez en créer un nouveau.
**Note**
Le OpenSearch cluster et la fonction Lambda que vous créez doivent être situés dans le même VPC que votre cluster de base de données Neptune, et le cluster OpenSearch doit être configuré en mode VPC (et non en mode Internet).
Nous vous recommandons d'utiliser une instance Neptune nouvellement créée pour l'utiliser avec OpenSearch le Service. Si vous utilisez une instance existante qui contient déjà des données, vous devez effectuer une synchronisation des données de OpenSearch service avant d'effectuer des requêtes, faute de quoi il peut y avoir des incohérences dans les données. Ce GitHub projet fournit un exemple de la manière d'effectuer la synchronisation : [Exporter Neptune vers 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).
**Important**
Lors de l'intégration à Amazon OpenSearch Service, Neptune nécessite la version 7.1 ou supérieure d'Elasticsearch et fonctionne avec les versions OpenSearch 2.3, 2.5 et les futures versions compatibles d'Opensearch.
**Note**
À partir de la [version 1.3.0.0 du moteur](engine-releases-1.3.0.0.md), Amazon Neptune prend en charge l'utilisation d'[ OpenSearch Amazon Service](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless.html) Serverless pour la recherche en texte intégral dans les requêtes Gremlin et SPARQL.
**Topics**
+ [Utilisation d'un AWS CloudFormation modèle pour démarrer Neptune-to-OpenSearch la réplication](full-text-search-cfn-create.md)
+ [Activation de la recherche en texte intégral dans les bases de données Neptune existantes](full-text-search-cfn-enabling.md)
+ [Mise à jour de l'interrogateur de flux](full-text-search-cfn-update-poller.md)
+ [Désactivation et réactivation du processus d'interrogateur de flux](full-text-search-using-pausing-poller.md)
# Utilisation d'un AWS CloudFormation modèle pour démarrer Neptune-to-OpenSearch la réplication
## Lancez un CloudFormation stack spécifique à votre région
Chacun des CloudFormation modèles ci-dessous crée une instance d'application streams-consumer dans une région spécifique AWS . Pour lancer la pile correspondante à l'aide de la CloudFormation console, cliquez sur l'un des boutons **Launch Stack** du tableau suivant, en fonction de la AWS région que vous souhaitez utiliser.
| Région | Afficher | Afficher dans Designer | Lancer |
| --- | --- | --- | --- |
| USA Est (Virginie du Nord) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| USA Est (Ohio) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| USA Ouest (Californie du Nord) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| USA Ouest (Oregon) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Canada (Centre) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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érique du Sud (São Paulo) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Stockholm) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Irlande) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Londres) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Paris) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Espagne) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Europe (Francfort) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Moyen-Orient (EAU) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Israël (Tel Aviv) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Afrique (Le Cap) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Hong Kong) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Tokyo) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Séoul) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Singapour) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Jakarta) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Asie-Pacifique (Mumbai) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Chine (Pékin) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
| Chine (Ningxia) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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 (US-Ouest) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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 (USA Est) | [Afficher](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [Afficher dans 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) |
Sur la page **Créer une pile** choisissez **Suivant**.
## Ajouter des détails sur la nouvelle OpenSearch pile que vous créez
Sur la page **Spécifier les détails de la pile**, vous pouvez utiliser de nombreux paramètres pour contrôler la configuration de la recherche en texte intégral :
**Nom de la pile** : nom de la nouvelle CloudFormation pile que vous créez. Vous pouvez généralement utiliser la valeur par défaut, `NeptuneStreamPoller`.
Sous **Paramètres**, indiquez ce qui suit :
**Configuration réseau pour le VPC sur lequel Streams Consumer est exécuté**
+ **`VPC`** : indiquez le nom du VPC où la fonction Lambda d'interrogation sera exécutée.
+ **`List of Subnet IDs`** : sous-réseaux avec lesquels une interface réseau est établie. Ajoutez des sous-réseaux correspondant à votre cluster Neptune.
+ **`List of Security Group Ids`**— Indiquez les groupes IDs de sécurité qui accordent un accès en écriture entrante à votre cluster de base de données Neptune source.
+ **`List of Route Table Ids`** : nécessaire pour créer un point de terminaison Amazon DynamoDB dans votre VPC Neptune, si vous n'en avez pas déjà un. Vous devez fournir une liste séparée par des virgules des tables de routage IDs associées aux sous-réseaux.
+ **`Require to create Dynamo DB VPC Endpoint`** : valeur booléenne qui correspond par défaut à `true`. Vous n'avez besoin de la remplacer par `false` que si vous avez déjà créé un point de terminaison DynamoDB dans votre VPC.
+ **`Require to create Monitoring VPC Endpoint`** : valeur booléenne qui correspond par défaut à `true`. Vous n'avez besoin de la modifier en `false` que si vous avez déjà créé un point de terminaison de surveillance dans votre VPC.
**Interrogateur de flux**
+ **`Application Name`** : vous pouvez généralement conserver la valeur par défaut (`NeptuneStream`). Si vous utilisez un nom différent, il doit être unique.
+ **`Memory size for Lambda Poller`** : utilisé pour définir la taille de mémoire disponible pour la fonction d'interrogateur Lambda. La valeur par défaut est 2 048 mégaoctets.
+ **`Lambda Runtime`** : langage utilisé dans la fonction Lambda qui extrait les éléments du flux Neptune. Vous pouvez définir ce paramètre sur `python3.9` ou sur `java8`.
+ **`S3 Bucket having Lambda code artifacts`** : laissez cette case vide, sauf si vous utilisez une fonction d'interrogation Lambda personnalisée qui se charge à partir d'un compartiment S3 différent.
+ **`S3 Key corresponding to Lambda Code artifacts`** : laissez ce champ vide, sauf si vous utilisez une fonction d'interrogation Lambda personnalisée.
+ **`StartingCheckpoint`** : point de contrôle de départ de l'interrogateur de flux. La valeur par défaut est `0:0`, ce qui signifie que l'interrogateur de flux doit commencer au début du flux Neptune.
+ **`StreamPollerInitialState`** : état initial de l'interrogateur. La valeur par défaut est `ENABLED`, ce qui signifie que la réplication du flux débutera dès que la création complète de la pile sera terminée.
+ **`Logging level for Lambda`** : en général, conservez la valeur par défaut, `INFO`.
+ **`Managed Policies for Lambda Execution`** : en général, laissez ce champ vide sauf si vous utilisez une fonction d'interrogation Lambda personnalisée.
+ **`Stream Records Handler`** : en général, laissez ce champ vide, sauf si vous utilisez un gestionnaire personnalisé pour les enregistrements dans les flux Neptune.
+ **`Maximum records Fetched from Stream`** : vous pouvez utiliser ce paramètre pour ajuster les performances. La valeur par défaut (`100`) est un bon endroit pour commencer. Le maximum autorisé est de 10 000. Plus le nombre est élevé, moins les appels réseau sont nécessaires pour lire les enregistrements du flux, mais plus la mémoire est nécessaire pour traiter les enregistrements.
+ **`Max wait time between two Polls (in Seconds)`** : détermine la fréquence à laquelle l'interrogateur Lambda est appelé pour interroger les flux Neptune. Définissez cette valeur sur 0 pour l'interrogation continue. La valeur maximale est de 3 600 secondes (1 heure). La valeur par défaut (60 secondes) est un bon point de départ, en fonction de la vitesse à laquelle vos données de graphe changent.
+ **`Maximum Continuous polling period (in Seconds)`** : permet de définir un délai d'expiration pour la fonction d'interrogation Lambda. Il doit être compris entre 5 secondes et 900 secondes. La valeur par défaut (600 secondes) est un bon point de départ.
+ **`Step Function Fallback Period`**— Le nombre d' step-function-fallback-periodunités devant attendre le sondeur, après quoi la fonction step est appelée via Amazon CloudWatch Events pour remédier à une panne. La valeur par défaut (5 minutes) est un bon point de départ.
+ **`Step Function Fallback Period Unit`** : unités de temps utilisées pour mesurer l'élément `Step Function Fallback Period` précédent (minutes, heures, jours). La valeur par défaut (minutes) est généralement suffisante.
+ **`Enable/disable creation of Elastic Search Mappings by Lambda`**— Signale la gestion enable/disable automatique des mappages Elastic Search par le stream poller. Les mappages Elastic Search sont essentiels à la conversion entre les types de données Neptune et Elastic Search. Cela ne doit être désactivé que par les utilisateurs avancés qui souhaitent contrôler directement et manuellement tous les mappages de leur index Elastic Search. La valeur par défaut est `true`.
+ **`Data replication scope`**— Détermine s'il faut répliquer à la fois les nœuds et les arêtes, ou uniquement les nœuds vers OpenSearch (cela s'applique uniquement aux données du moteur Gremlin). La valeur par défaut (All) est généralement un bon endroit pour commencer.
+ **`Ignore OpenSearch missing document error`**— Indicateur permettant de déterminer si une erreur liée à un document manquant OpenSearch peut être ignorée. Les erreurs de document manquant se produisent rarement, mais nécessitent une intervention manuelle si elles ne sont pas ignorées. : la valeur par défaut (`True`) est généralement un bon point de départ.
+ **`Enable Non-String Indexing`** : indicateur permettant d'activer ou de désactiver l'indexation des champs sans contenu de chaîne. Si cet indicateur est défini sur`true`, les champs autres que des chaînes sont indexés OpenSearch, ou si `false` seuls les champs de chaîne sont indexés. La valeur par défaut est `true`.
+ **`Properties to exclude from being inserted into OpenSearch`**— Liste séparée par des virgules de clés de propriété ou de prédicat à exclure de l'indexation. OpenSearch Si cette valeur de paramètre CFN est laissée vide, toutes les clés de propriété sont indexées.
+ **`Datatypes to exclude from being inserted into OpenSearch`**— Liste séparée par des virgules de types de données de propriétés ou de prédicats à exclure de l'indexation. OpenSearch Si cette valeur de paramètre CFN est laissée vide, toutes les valeurs de propriété qui peuvent être converties en toute sécurité en OpenSearch types de données sont indexées.
**Flux Neptune**
+ **`Endpoint of source Neptune Stream`** : (*obligatoire*) prend deux formes :
+ **`https://your DB cluster:port/propertygraph/stream`** (ou son alias, `https://your DB cluster:port/pg/stream`).
+ `https://your DB cluster:port/sparql/stream`
+ **`Neptune Query Engine`** : choisissez Gremlin ou SPARQL.
+ **`Is IAM Auth Enabled?`** : si votre cluster de bases de données Neptune utilise l'authentification IAM, définissez ce paramètre sur `true`.
+ **`Neptune Cluster Resource Id`** : si votre cluster de bases de données Neptune utilise l'authentification IAM, définissez ce paramètre sur l'ID de ressource du cluster. L'ID de ressource n'est pas le même que l'ID de cluster. Elle prend plutôt la forme : `cluster-` suivi de 28 caractères alphanumériques. Vous pouvez le trouver sous **Détails du cluster** dans la console Neptune.
**OpenSearch Cluster cible**
+ **`Endpoint for OpenSearch service`**— (Obligatoire) Indiquez le point de terminaison du OpenSearch service dans votre VPC.
+ **`Number of Shards for OpenSearch Index`** : la valeur par défaut (5) est généralement un bon point de départ.
+ **`Number of Replicas for OpenSearch Index`** : la valeur par défaut (1) est généralement un bon point de départ.
+ **`Geo Location Fields for Mapping`** : si vous utilisez des champs de géolocalisation, répertoriez les clés de propriété ici.
**alerte**
+ **`Require to create Cloud watch Alarm`**— Réglez ce `true` paramètre sur si vous souhaitez créer une CloudWatch alarme pour la nouvelle pile.
+ **`SNS Topic ARN for Cloudwatch Alarm Notifications`**— L'ARN de la rubrique SNS où les notifications CloudWatch d'alarme doivent être envoyées (uniquement nécessaire si les alarmes sont activées).
+ **`Email for Alarm Notifications`** : adresse e-mail à laquelle les notifications d'alarme doivent être envoyées (uniquement si les alarmes sont activées).
Pour la destination de la notification d'alarme, vous pouvez ajouter la rubrique SNS uniquement, l'adresse e-mail uniquement ou les deux.
## Exécuter le CloudFormation modèle
Vous pouvez maintenant terminer le processus de provisionnement d'une instance d'application grand public de flux Neptune comme suit :
1. Dans CloudFormation, sur la page **Spécifier les détails de la pile**, choisissez **Next**.
1. Dans la page **Options**, choisissez **Suivant**.
1. Sur la page **Vérification**, cochez la première case pour accepter que CloudFormation créera des ressources IAM. Cochez la deuxième case pour confirmer `CAPABILITY_AUTO_EXPAND` comme nouvelle pile.
**Note**
`CAPABILITY_AUTO_EXPAND` accepte explicitement que les macros soient étendues lors de la création de la pile, sans révision préalable. Les utilisateurs créent souvent un jeu de modifications à partir d'un modèle traité, de sorte que les modifications apportées par les macros puissent être révisées avant la création de la pile. Pour plus d'informations, consultez le fonctionnement de l' CloudFormation [CreateStack](https://docs.aws.amazon.com/AWSCloudFormation/latest/APIReference/API_CreateStack.html)API dans le Guide de *référence des AWS CloudFormation API*.
Ensuite, choisissez **Créer**.
# Activation de la recherche en texte intégral dans les bases de données Neptune existantes
Il s'agit des approches établies pour permettre la recherche en texte intégral dans les bases de données Amazon Neptune existantes. Selon que vous pouvez suspendre vos charges de travail d'écriture ou non, les étapes peuvent varier légèrement. Ce guide décrit les étapes recommandées pour les deux scénarios : quand vous pouvez suspendre les écritures et quand vous ne le pouvez pas. Il couvre l'activation des flux Neptune, la création d'un clone de base de données, la synchronisation des données avec un OpenSearch domaine et la configuration de mises à jour continues. Les conseils s'appuient sur des AWS services et des outils open source pour rationaliser le processus et minimiser les temps d'arrêt.
## Si vous pouvez suspendre vos charges de travail d'écriture
La méthode la plus adaptée pour activer la recherche en texte intégral dans une base de données Neptune existante est généralement la suivante, à condition que vous puissiez suspendre les charges de travail d'écriture. Elle nécessite de créer un clone, d'activer les flux à l'aide d'un paramètre de cluster et de redémarrer toutes les instances. La création d'un clone étant une opération relativement rapide, le temps d'arrêt requis est limité.
Voici les étapes requises :
1. Arrêtez toutes les charges de travail d'écriture sur la base de données.
1. Activez les flux sur la base de données (voir [Activation de Neptune Streams](streams-using-enabling.md)).
1. Créez un clone de la base de données (voir [Clonage de base de données dans Neptune](manage-console-cloning.md)).
1. Relancez les charges de travail d'écriture.
1. Utilisez l'[export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)outil sur github pour effectuer une synchronisation unique entre la base de données clonée et le OpenSearch domaine.
1. Utilisez le [modèle CloudFormation de votre région](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region) pour démarrer la synchronisation à partir de la base de données d'origine avec une mise à jour continue (aucune modification de configuration n'est nécessaire dans le modèle).
1. Supprimez la base de données clonée et la CloudFormation pile créée pour l'`export-neptune-to-elasticsearch`outil.
**Note**
En cas d'utilisation [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)avec Opensearch Serverless, les données `LambdaExecutionRole` créées par la pile [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)Cloudformation doivent être ajoutées à la [politique d'accès aux données d'Opensearch pour que les données](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless-data-access.html) soient correctement répliquées.
## Si vous ne pouvez pas suspendre vos charges de travail d'écriture
Si vous ne pouvez pas vous permettre de suspendre les charges de travail d'écriture sur la base de données, voici une approche qui nécessite encore moins de temps d'arrêt que celle recommandée ci-dessus, mais elle doit être appliquée avec prudence :
1. Activez les flux sur la base de données (voir [Activation de Neptune Streams](streams-using-enabling.md)).
1. Créez un clone de la base de données (voir [Clonage de base de données dans Neptune](manage-console-cloning.md)).
1. Obtenez les derniers `eventID` des flux de la base de données clonée en exécutant une commande de ce type sur le point de terminaison de l'API Streams (voir [Appel de l'API REST Neptune Streams](streams-using-api-call.md) pour plus d'informations) :
```
curl "https://(your neptune endpoint):(port)/(propertygraph or sparql)/stream?iteratorType=LATEST"
```
Notez les valeurs des champs `commitNum` et `opNum` dans l'objet `lastEventId` de la réponse.
1. Utilisez l'[export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch)outil sur github pour effectuer une synchronisation unique entre la base de données clonée et le OpenSearch domaine.
1. Utilisez le [modèle CloudFormation de votre région](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region) pour démarrer la synchronisation à partir de la base de données d'origine avec une mise à jour continue.
Apportez la modification suivante lors de la création de la pile : sur la page des détails de la pile, dans la section **Paramètres**, définissez la valeur du `StartingCheckpoint` champ sur **commitNum** : **opnum** en utilisant les `opNum` valeurs `commitNum` et que vous avez enregistrées ci-dessus.
1. Supprimez la base de données clonée et la CloudFormation pile créée pour l'`export-neptune-to-elasticsearch`outil.
# Mise à jour de l'interrogateur de flux
Les informations suivantes décrivent les étapes nécessaires pour mettre à jour le Stream Poller avec les derniers artefacts Lambda à l'aide de AWS la console de gestion.
## Pour mettre à jour l'interrogateur de flux avec les derniers artefacts Lambda
Pour mettre à jour l'interrogateur de flux avec les derniers artefacts Lambda, procédez comme suit :
1. Dans le AWS Management Console, naviguez jusqu'à la CloudFormation pile parent principale CloudFormation et sélectionnez-la.
1. Sélectionnez l'option **Mettre à jour** correspondant à la pile.
1. Sélectionnez **Remplacer le modèle actuel**.
1. Pour la source du modèle, choisissez **URL Amazon S3** et indiquez l'URL S3 suivante :
```
https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json
```
1. Sélectionnez **Next** sans modifier aucun CloudFormation paramètre.
1. Choisissez **Mettre à jour la pile**.
La pile met à jour les artefacts Lambda avec les artefacts les plus récents.
## Extension de l'interrogateur de flux pour prendre en charge les champs personnalisés
L'interrogateur de flux actuel peut facilement être étendu pour écrire du code personnalisé permettant de gérer des champs personnalisés, comme expliqué en détail dans ce billet de blog : [Capture graph changes using Neptune Streams](https://aws.amazon.com/blogs/database/capture-graph-changes-using-neptune-streams/).
**Note**
Lorsque vous ajoutez un champ personnalisé OpenSearch, assurez-vous d'ajouter le nouveau champ en tant qu'objet interne d'un prédicat (voir[Modèle de données de recherche en texte intégral Neptune](full-text-search-model.md)).
# Désactivation et réactivation du processus d'interrogateur de flux
**Avertissement**
Soyez prudent lorsque vous désactivez le processus d'interrogateur de flux. Une perte de données peut se produire si le processus est suspendu au-delà de la période d'expiration des flux. La fenêtre par défaut est de 7 jours, mais à partir de la version [1.2.0.0](engine-releases-1.2.0.0.md) du moteur, vous pouvez définir une période d'expiration des flux personnalisée pouvant aller jusqu'à 90 jours.
# Désactivation (interruption) du processus d'interrogateur de flux
1. Connectez-vous à la EventBridge console Amazon AWS Management Console et ouvrez-la à l'adresse [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. Dans le volet de navigation, sélectionnez **Règles**.
1. Sélectionnez la règle dont le nom contient le nom que vous avez fourni comme **nom d'application** dans le CloudFormation modèle que vous avez utilisé pour configurer le stream poller.
1. Choisissez **Désactiver**.
1. Ouvrez la console Step Functions à l'adresse [https://console.aws.amazon.com/states/](https://console.aws.amazon.com/states/).
1. Sélectionnez la fonction d'étape en cours d'exécution qui correspond au processus d'interrogateur de flux. Encore une fois, le nom de cette fonction d'étape contient le nom que vous avez fourni comme **nom d'application** dans le CloudFormation modèle que vous avez utilisé pour configurer le stream poller. Vous pouvez effectuer un filtrage par statut d'exécution des fonctions afin de ne voir que les fonctions **en cours d'exécution**.
1. Choisissez **Arrêter**.
# Réactivation du processus d'interrogateur de flux
1. Connectez-vous à la EventBridge console Amazon AWS Management Console et ouvrez-la à l'adresse [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. Dans le volet de navigation, sélectionnez **Règles**.
1. Sélectionnez la règle dont le nom contient le nom que vous avez fourni comme **nom d'application** dans le CloudFormation modèle que vous avez utilisé pour configurer le stream poller.
1. Sélectionnez **Activer**. La règle d'événement basée sur l'intervalle planifié spécifié déclenche désormais une nouvelle exécution de la fonction d'étape.