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.
Utilisation d'un AWS CloudFormation modèle pour démarrer Neptune-to-OpenSearch la réplication
Lancez un AWS CloudFormation stack spécifique à votre région
Chacun des AWS 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 AWS CloudFormation console, cliquez sur l'un des boutons Launch Stack du tableau suivant, en fonction de la AWS région que vous souhaitez utiliser.
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 AWS 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 serveur VPC Where the Streams Consumer Run
VPC
— Indiquez le nom de l'VPCendroit 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
— Cela est 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 devez uniquement le remplacer parfalse
si vous avez déjà créé un point de terminaison DynamoDB dans votre. VPCRequire to create Monitoring VPC Endpoint
: valeur booléenne qui correspond par défaut àtrue
. Vous devez uniquement le remplacer parfalse
si vous avez déjà créé un point de terminaison de surveillance dans votreVPC.
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 surpython3.9
ou surjava8
.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 est0: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 estENABLED
, 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émentStep Function Fallback Period
précédent (minutes, heures, jours). La valeur par défaut (minutes) est généralement suffisante.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 surtrue
, les champs autres que des chaînes sont indexés OpenSearch, ou sifalse
seuls les champs de chaîne sont indexés. L’argument par défaut esttrue
.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 CFN paramètre 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 CFN paramètre 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://
(ou son alias,your DB cluster
:port
/propertygraph/streamhttps://
).your DB cluster
:port
/pg/streamhttps://
your DB cluster
:port
/sparql/stream
Neptune Query Engine
— Choisissez Gremlin ouSPARQL.Is IAM Auth Enabled?
— Si votre cluster de base de données Neptune utilise l'IAMauthentification, définissez ce paramètre sur.true
Neptune Cluster Resource Id
— Si votre cluster de base de données Neptune utilise l'IAMauthentification, 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 votreVPC.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 cetrue
paramètre sur si vous souhaitez créer une CloudWatch alarme pour la nouvelle pile.SNS Topic ARN for Cloudwatch Alarm Notifications
— Le SNS sujet dans ARN lequel 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 SNS uniquement un e-mail, ou les deux SNS et un e-mail.
Exécuter le AWS CloudFormation modèle
Vous pouvez maintenant terminer le processus de provisionnement d'une instance d'application grand public de flux Neptune comme suit :
Dans AWS CloudFormation, sur la page Spécifier les détails de la pile, choisissez Next.
Dans la page Options, choisissez Suivant.
-
Sur la page Révision, cochez la première case pour confirmer que cela AWS CloudFormation créera des IAM ressources. 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, voir l' AWS CloudFormation CreateStackAPIopération dans la AWS CloudFormation APIréférence.Ensuite, choisissez Créer.