Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Verwenden AWS CloudFormation , um die Neptun-zu-Neptune-Replikation mit der Streams-Consumer-Anwendung einzurichten
Sie können eine AWS CloudFormation Vorlage verwenden, um die Neptune Streams-Consumer-Anwendung so einzurichten, dass sie die Neptun-zu-Neptune-Replikation unterstützt.
Themen
Wählen AWS CloudFormation Sie eine Vorlage für Ihre Region
Um den entsprechenden AWS CloudFormation Stack auf der AWS CloudFormation Konsole zu starten, wählen Sie je nach AWS Region, die Sie verwenden möchten, eine der Schaltflächen „Stack starten“ in der folgenden Tabelle.
Wählen Sie auf der Seite Create Stack (Stack erstellen) die Option Next (Weiter) aus.
Hinzufügen von Details zu dem von Ihnen erstellten Neptune-Streams-Consumer-Stack
Auf der Seite Stackdetails angeben finden Sie Eigenschaften und Parameter für die Einrichtung der Anwendung steuern können:
Stack-Name — Der Name des neuen AWS CloudFormation Stacks, den Sie erstellen. Sie können in der Regel den Standardwert NeptuneStreamPoller verwenden.
Geben Sie unter Parameter, Folgendes ein:
Netzwerkkonfiguration für die VPC, in der der Streams-Consumer ausgeführt wird
VPC– Geben Sie den Namen der VPC an, in der die abfragende Lambda-Funktion ausgeführt werden wird.SubnetIDs– Die Subnetze, für die eine Netzwerkschnittstelle eingerichtet ist. Fügen Sie Subnetze hinzu, die Ihrem Neptune-Cluster entsprechen.SecurityGroupIds– Geben Sie die IDs von Sicherheitsgruppen an, die Schreibzugriff für den eingehenden Datenverkehr in Ihrem Neptune-DB-Cluster gewähren.RouteTableIds– Dies wird benötigt, um einen Amazon-DynamoDB-Endpunkt in Ihrer Neptune-VPC zu erstellen, wenn noch keiner vorhanden ist. Sie müssen eine durch Komma getrennte Liste der Routing-Tabellen-IDs angeben, die den Subnetzen zugeordnet sind.CreateDDBVPCEndPoint– Ein boolescher Wert, der standardmäßig auftruefestgelegt ist und angibt, ob ein Dynamo-DB-VPC-Endpunkt erstellt werden muss. Sie müssen ihn nur infalseändern, wenn Sie bereits einen DynamoDB-Endpunkt in Ihrer VPC erstellt haben.CreateMonitoringEndPoint– Ein boolescher Wert, der standardmäßig auftruefestgelegt ist und angibt, ob ein überwachender VPC-Endpunkt erstellt werden muss. Sie müssen ihn nur infalseändern, wenn Sie bereits einen Überwachungsendpunkt in Ihrer VPC erstellt haben.
Stream-Poller
ApplicationName– Sie können diesen Satz in der Regel beim Standardwert (NeptuneStream) belassen. Wenn Sie einen anderen Namen verwenden, muss dieser eindeutig sein.LambdaMemorySize– Wird verwendet, um die Speichergröße festzulegen, die für die Lambda-Poller-Funktion verfügbar ist. Der Standardwert ist 2.048 Megabyte.LambdaRuntime– Die Sprache, die in der Lambda-Funktion verwendet wird, mit der Elemente aus dem Neptune-Stream abgerufen werden. Sie können dies aufpython3.9oderjava8festlegen.LambdaS3Bucket– Der Amazon-S3-Bucket, der Lambda-Code-Artefakte enthält. Lassen Sie dieses Feld leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Polling-Funktion, die aus einem anderen Amazon-S3-Bucket geladen wird.LambdaS3Key– Der Amazon-S3-Schlüssel, der Ihren Lambda-Code-Artefakten entspricht. Lassen Sie dieses Feld leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Polling-Funktion.LambdaLoggingLevel– Belassen Sie diesen Satz grundsätzlich beim Standardwert,INFO.ManagedPolicies– Listet die verwalteten Richtlinien auf, die für die Ausführung Ihrer Lambda-Funktion verwendet werden sollen. Lassen Sie dieses Feld grundsätzlich leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Polling-Funktion.StreamRecordsHandler– Lassen Sie dieses Feld grundsätzlich leer, es sei denn, Sie verwenden einen benutzerdefinierten Handler für die Datensätze in Neptune-Streams.StreamRecordsBatchSize– Die maximale Anzahl von Datensätzen, die aus dem Stream abgerufen werden sollen. Sie können mit diesem Parameter die Leistung optimieren. Der Standardwert (5000) ist ein guter Anfangspunkt. Der maximal zulässige Wert ist 10.000. Je höher die Zahl ist, desto weniger Netzwerkaufrufe werden benötigt, um Datensätze aus dem Stream zu lesen. Allerdings ist umso mehr Speicher ist erforderlich, um die Datensätze zu verarbeiten. Niedrigere Werte dieses Parameters führen zu einem geringeren Durchsatz.MaxPollingWaitTime– Die maximale Wartezeit zwischen zwei Abfragen (in Sekunden). Legt die Häufigkeit fest, mit der der Lambda-Poller aufgerufen wird, um die Neptune-Streams abzufragen. Legen Sie diesen Wert für kontinuierliche Abfragen auf „0“ fest. Die Höchstwert beträgt 3.600 Sekunden (1 Stunde). Der Standardwert (60 Sekunden) ist ein guter Ausgangspunkt, je nachdem, wie schnell sich Ihre Graphdaten ändern.MaxPollingInterval– Die maximale kontinuierliche Polling-Dauer (in Sekunden). Mit dieser Einstellung können Sie ein Timeout für die Lambda-Polling-Funktion festlegen. Der Wert sollte im Bereich zwischen 5 und 900 Sekunden liegen. Der Standardwert (600 Sekunden) ist ein guter Ausgangspunkt.StepFunctionFallbackPeriod— Die Anzahl der Einheiten, die step-function-fallback-period auf den Poller warten sollen. Danach wird die Step-Funktion über Amazon CloudWatch Events aufgerufen, um sich nach einem Ausfall zu erholen. Der Standardwert (5 Minuten) ist ein guter Anfangspunkt.StepFunctionFallbackPeriodUnit– Die Zeiteinheiten, die verwendet wurden, um den vorhergehenden Wert fürStepFunctionFallbackPeriodUnit(minutes,hours, oderdays) zu messen. Der Standardwert (minutes) ist im Allgemeinen ausreichend.
Neptune-Stream
-
NeptuneStreamEndpoint– (Erforderlich) Der Endpunkt des Neptun-Quellstreams. Dies erfolgt auf eine der folgenden beiden Arten:https://(oder dessen Alias,your DB cluster:port/propertygraph/streamhttps://).your DB cluster:port/pg/streamhttps://.your DB cluster:port/sparql/stream
Neptune Query Engine– Wählen Sie Gremlin, openCypher oder SPARQL aus.IAMAuthEnabledOnSourceStream– Wenn Ihr Neptune-DB-Cluster die IAM-Authentifizierung verwendet, legen Sie diesen Parameter auftruefest.StreamDBClusterResourceId– Wenn Ihr Neptune-DB-Cluster die IAM-Authentifizierung verwendet, legen Sie diesen Parameter auf die Cluster-Ressourcen-ID fest. Die Ressourcen-ID ist nicht mit der Cluster-ID identisch. Stattdessen hat sie das folgende Format:cluster-gefolgt von 28 alphanumerischen Zeichen. Sie finden sie unter Cluster-Details in der Neptune-Konsole.
Neptune-DB-Ziel-Cluster
-
TargetNeptuneClusterEndpoint– Der Cluster-Endpunkt (nur Hostname) des Ziel-Clusters für die Sicherung.Beachten Sie, dass Sie nicht auch
TargetSPARQLUpdateEndpointangeben können, wenn SieTargetNeptuneClusterEndpointangeben. -
TargetNeptuneClusterPort– Die Port-Nummer für den Ziel-Cluster.Beachten Sie, dass die Einstellung für
TargetNeptuneClusterPortignoriert wird, wenn SieTargetSPARQLUpdateEndpointangeben. -
IAMAuthEnabledOnTargetCluster– Wird auf true festgelegt, wenn die IAM-Authentifizierung für den Ziel-Cluster aktiviert werden soll. -
TargetAWSRegion— Die AWS Region des Ziel-Backup-Clusters, z. B.us-east-1). Sie müssen diesen Parameter nur angeben, wenn sich die AWS Region des Ziel-Backup-Clusters von der Region des Neptune-Quell-Clusters unterscheidet, wie im Fall einer regionsübergreifenden Replikation. Wenn Quell- und Zielregion identisch sind, ist dieser Parameter optional.Beachten Sie, dass der Vorgang fehlschlägt, wenn der TargetAWSRegion Wert keine gültige AWS Region ist, die Neptune unterstützt.
-
TargetNeptuneDBClusterResourceId– Optional: Dies ist nur notwendig, wenn die IAM-Authentifizierung für den DB-Ziel-Cluster aktiviert ist. Auf die Ressourcen-ID des Ziel-Clusters festgelegt. -
SPARQLTripleOnlyMode– Boolesches Flag, das festlegt, ob der Nur-Tripel-Modus aktiviert ist. Im Nur-Tripel-Modus gibt es keine Replikation mit benannten Diagrammen. Der Standardwert istfalse. -
TargetSPARQLUpdateEndpoint– URL des Zielendpunkts für das SPARQL-Update, z. B.https://abc.com/xyz. Dieser Endpunkt kann jeder SPARQL-Speicher sein, der Quads oder Tripel unterstützt.Beachten Sie, dass Sie nicht auch
TargetNeptuneClusterEndpointangeben können, wenn SieTargetSPARQLUpdateEndpointangeben, und dass die Einstellung fürTargetNeptuneClusterPortignoriert wird. -
BlockSparqlReplicationOnBlankNode— Boolesches Flag, das, wenn es auf gesetzt isttrue, die Replikation von Daten BlankNode in SPARQL (RDF) stoppt. Der Standardwert istfalse.
Alarm
Required to create Cloud watch Alarm— Setzen Sie diesen Wert auf,truewenn Sie einen CloudWatch Alarm für den neuen Stack erstellen möchten.SNS Topic ARN for Cloudwatch Alarm Notifications— Das SNS-Thema ARN, an das CloudWatch Alarmbenachrichtigungen gesendet werden sollen (nur erforderlich, wenn Alarme aktiviert sind).Email for Alarm Notifications– Die E-Mail-Adresse, an die Alarmbenachrichtigungen gesendet werden sollen (nur notwendig, wenn Alarme aktiviert sind).
Als Ziel der Alarmbenachrichtigung können Sie nur SNS, nur E-Mail oder sowohl SNS als auch E-Mail hinzufügen.
Führen Sie die Vorlage aus AWS CloudFormation
Jetzt können Sie den Prozess für die Bereitstellung einer Neptune-Streams-Consumer-Anwendungs-Instance wie folgt abschließen:
Wählen Sie auf der Seite „Stack-Details angeben“ die Option Weiter aus. AWS CloudFormation
Wählen Sie auf der Seite Optionen Weiter aus.
-
Aktivieren Sie auf der Seite Überprüfen das erste Kontrollkästchen, um zu bestätigen, dass AWS CloudFormation IAM-Ressourcen erstellt. Aktivieren Sie das zweite Kontrollkästchen, um
CAPABILITY_AUTO_EXPANDfür den neuen Stack zu bestätigen.Anmerkung
CAPABILITY_AUTO_EXPANDbestätigt explizit, dass Makros ohne vorherige Überprüfung beim Erstellen des Stacks erweitert werden. Benutzer erstellen häufig einen Änderungssatz aus einer verarbeiteten Vorlage, sodass die von Makros durchgeführten Änderungen überprüft werden können, ehe der Stack tatsächlich erstellt wird. Weitere Informationen zur AWS CloudFormation CreateStackAPI finden Sie in der AWS CloudFormation API-Referenz.Wählen Sie die Option Erstellen aus.
Aktualisieren des Stream-Pollers mit den neuesten Lambda-Artefakten
Sie können den Stream-Poller wie folgt mit den neuesten Lambda-Code-Artefakten aktualisieren:
Navigieren Sie im AWS Management Console zum übergeordneten AWS CloudFormation Hauptstapel AWS CloudFormation und wählen Sie ihn aus.
Wählen Sie die Option Aktualisieren für den Stack aus.
Wählen Sie Aktuelle Vorlage ersetzen aus.
-
Wählen Sie als Vorlagenquelle Amazon-S3-URL aus und geben Sie die folgende S3-URL ein:
https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_neptune.json Wählen Sie Weiter, ohne die AWS CloudFormation Parameter zu ändern.
Wählen Sie Stack aktualisieren aus.
Der Stack aktualisiert jetzt die Lambda-Artefakte mit den neuesten Artefakten.
