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.
Mit einem AWS CloudFormation Vorlage zum Starten der Neptune-to-Replikation OpenSearch
Starten Sie ein AWS CloudFormation Stack, der für Ihre Region spezifisch ist
Jeder der AWS CloudFormation Die folgenden Vorlagen erstellen eine Streams-Consumer-Anwendungsinstanz in einem bestimmten AWS Region. Um den entsprechenden Stack mit dem zu starten AWS CloudFormation Konsole, wählen Sie in der folgenden Tabelle eine der Schaltflächen Stack starten, abhängig von AWS Region, die Sie verwenden möchten.
Wählen Sie auf der Seite Create Stack (Stack erstellen) die Option Next (Weiter) aus.
Fügen Sie Details zu dem neuen OpenSearch Stack hinzu, den Sie erstellen
Auf der Seite Stack-Details angeben finden Sie Eigenschaften und Parameter für die Einrichtung der Volltextsuche.
Stack-Name — Der Name des neuen AWS CloudFormation Stapel, den Sie erstellen. Sie können in der Regel den Standardwert NeptuneStreamPoller verwenden.
Geben Sie unter Parameter, Folgendes ein:
Netzwerkkonfiguration für den VPC Ort, an dem der Streams-Verbraucher ausgeführt wird
VPC— Geben Sie den Namen der VPC Stelle an, an der die Lambda-Abfragefunktion ausgeführt werden soll.List of Subnet IDs– die Subnetze, für die eine Netzwerkschnittstelle eingerichtet ist. Fügen Sie Subnetze hinzu, die Ihrem Neptune-Cluster entsprechen.List of Security Group Ids— Geben Sie die Sicherheitsgruppen IDs an, die eingehenden Schreibzugriff auf Ihren Neptune-DB-Quellcluster gewähren.List of Route Table Ids— Dies ist erforderlich, um einen Amazon DynamoDB DynamoDB-Endpunkt in Ihrem Neptune zu erstellenVPC, falls Sie noch keinen haben. Sie müssen eine durch Kommas getrennte Liste der Routing-Tabellen angeben, die den Subnetzen zugeordnet sind. IDsRequire to create Dynamo DB VPC Endpoint– Ein boolescher Wert, der standardmäßigtruelautet. Sie müssen es nur ändern,falsewenn Sie in Ihrem bereits einen DynamoDB-Endpunkt erstellt haben. VPCRequire to create Monitoring VPC Endpoint– Ein boolescher Wert, der standardmäßigtruelautet. Sie müssen es nur ändern,falsewenn Sie in Ihrem bereits einen Überwachungsendpunkt erstellt haben. VPC
Stream-Poller
Application Name– Sie können diesen Satz in der Regel auf dem Standardwert (NeptuneStream) belassen. Wenn Sie einen anderen Namen verwenden, muss dieser eindeutig sein.Memory size for Lambda Poller– Wird verwendet, um die Speichergröße festzulegen, die für die Lambda-Poller-Funktion verfügbar ist. Der Standardwert ist 2.048 Megabyte.Lambda Runtime– Die Sprache, die in der Lambda-Funktion verwendet wird, mit der Elemente aus dem Neptune-Stream abgerufen werden. Sie können dies entweder aufpython3.9oder aufjava8setzen.S3 Bucket having Lambda code artifacts– Lassen Sie dieses Feld leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Abfragefunktion, die aus einem anderen S3-Bucket geladen wird.S3 Key corresponding to Lambda Code artifacts– Lassen Sie dieses Feld leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Abfragefunktion.StartingCheckpoint– Der Start-Prüfpunkt für den Stream-Poller. Die Standardeinstellung ist0:0, was bedeutet, dass mit dem Anfang des Neptune-Streams begonnen wird.StreamPollerInitialState– Der anfängliche Zustand des Pollers. Die Standardeinstellung istENABLED, was bedeutet, dass die Stream-Replikation beginnt, sobald die gesamte Stack-Erstellung abgeschlossen ist.Logging level for Lambda– Belassen Sie diesen Satz generell auf dem Standardwert,INFOManaged Policies for Lambda Execution– Lassen Sie dieses Feld im Allgemeinen leer, es sei denn, Sie verwenden eine benutzerdefinierte Lambda-Abfragefunktion.Stream Records Handler– Lassen Sie dieses Feld im Allgemeinen leer, es sei denn, Sie verwenden einen benutzerdefinierten Handler für die Datensätze in Neptune-Streams.Maximum records Fetched from Stream– Mit diesem Parameter können Sie die Leistung optimieren. Der Standardwert (100) 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.Max wait time between two Polls (in Seconds)– Legt fest, wie häufig 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.Maximum Continuous polling period (in Seconds)– Wird verwendet, um ein Timeout für die Lambda-Abfragefunktion festzulegen. Es sollte zwischen 5 und 900 Sekunden liegen. Der Standardwert (600 Sekunden) ist ein guter Ausgangspunkt.Step Function Fallback Period— Die Anzahl der step-function-fallback-period Einheiten, die auf den Poller gewartet werden 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.Step Function Fallback Period Unit– Die Zeiteinheiten (Minuten, Stunden, Tage), die zum Messen der vorhergehendenStep Function Fallback Periodverwendet werden. Der Standardwert (Minuten) ist im Allgemeinen ausreichend.Data replication scope— Legt fest, ob sowohl Knoten als auch Kanten oder nur Knoten repliziert werden sollen OpenSearch (dies gilt nur für Gremlin-Engine-Daten). Der Standardwert (All (Alle)) ist in der Regel ein guter Anfangspunkt.Ignore OpenSearch missing document error— Markierung, um zu bestimmen, ob ein Fehler in einem fehlenden Dokument ignoriert OpenSearch werden kann. „Fehlendes Dokument“-Fehler können vereinzelt vorkommen, erfordern jedoch ein manuelles Eingreifen, wenn sie nicht ignoriert werden. Der Standardwert (True) ist in der Regel ein guter Ausgangspunkt.Enable Non-String Indexing– Flag zum Aktivieren oder Deaktivieren der Indizierung von Feldern, die keinen Zeichenfolgeninhalt haben. Wenn dieses Kennzeichen auf gesetzt ist, werden Feldertrue, die keine Zeichenfolgen sind, indexiert OpenSearch, oder wennfalse, werden nur Zeichenkettenfelder indexiert. Der Standardwert isttrue.Properties to exclude from being inserted into OpenSearch— Eine durch Kommas getrennte Liste von Eigenschafts- oder Prädikatschlüsseln, die von der Indizierung ausgeschlossen werden sollen. OpenSearch Wenn dieser CFN Parameterwert leer gelassen wird, werden alle Eigenschaftsschlüssel indexiert.Datatypes to exclude from being inserted into OpenSearch— Eine durch Kommas getrennte Liste von Eigenschaften- oder Prädikat-Datentypen, die von der Indizierung ausgeschlossen werden sollen. OpenSearch Wenn dieser CFN Parameterwert leer gelassen wird, werden alle Eigenschaftswerte, die sicher in Datentypen konvertiert werden können, indexiert. OpenSearch
Neptune-Stream
-
Endpoint of source Neptune Stream– (Erforderlich) Dies kann eine von zwei Formen haben: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 oder. SPARQLIs IAM Auth Enabled?— Wenn Ihr Neptune-DB-Cluster IAM Authentifizierung verwendet, setzen Sie diesen Parameter auf.trueNeptune Cluster Resource Id— Wenn Ihr Neptune-DB-Cluster IAM Authentifizierung verwendet, setzen Sie diesen Parameter auf die Cluster-Ressourcen-ID. 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.
Zielcluster OpenSearch
Endpoint for OpenSearch service— (Erforderlich) Geben Sie den Endpunkt für den OpenSearch Dienst in Ihrem anVPC.Number of Shards for OpenSearch Index– Der Standardwert (5) ist in der Regel ein guter Ausgangspunkt.Number of Replicas for OpenSearch Index– Der Standardwert (1) ist in der Regel ein guter Ausgangspunkt.Geo Location Fields for Mapping– Wenn Sie Geolocation-Felder verwenden, führen Sie hier die Eigenschaftsschlüssel auf.
Alarm
Require to create Cloud watch Alarm— Stellen Sie dies auf ein,truewenn Sie einen CloudWatch Alarm für den neuen Stack erstellen möchten.SNS Topic ARN for Cloudwatch Alarm Notifications— Das SNS ThemaARN, 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 erforderlich, wenn Alarme aktiviert sind).
Als Ziel der Alarmbenachrichtigung können Sie SNS nur, nur E-Mail oder beides SNS und E-Mail hinzufügen.
Führen Sie den AWS CloudFormation Vorlage
Jetzt können Sie den Prozess für die Bereitstellung einer Neptune-Streams-Consumer-Anwendungs-Instance wie folgt abschließen:
In AWS CloudFormation, wählen Sie auf der Seite „Stack-Details angeben“ die Option Weiter aus.
Wählen Sie auf der Seite Optionen Weiter aus.
-
Aktivieren Sie auf der Seite „Überprüfen“ das erste Kontrollkästchen, um dies zu bestätigen AWS CloudFormation wird IAM Ressourcen erstellen. 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 finden Sie im AWS CloudFormation CreateStackAPIOperation in der AWS CloudFormation APIReferenz.Wählen Sie die Option Erstellen aus.
