Utilizzo AWS CloudFormation per configurare la replica da Neptune-Neptune con l'applicazione Streams Consumer

È possibile utilizzare un AWS CloudFormation modello per configurare l'applicazione consumer Neptune Streams per supportare la replica da Neptune a Neptune.

Scegli un modello per la tua regione AWS CloudFormation

Per avviare lo AWS CloudFormation stack appropriato sulla AWS CloudFormation console, scegli uno dei pulsanti Launch Stack nella tabella seguente, a seconda della AWS regione che desideri utilizzare.

Regione	Vista	Visualizzazione in Designer	Avvia
Stati Uniti orientali (Virginia settentrionale)	Visualizzazione	Visualizzazione in Designer
Stati Uniti orientali (Ohio)	Visualizzazione	Visualizzazione in Designer
Stati Uniti occidentali (California settentrionale)	Visualizzazione	Visualizzazione in Designer
US West (Oregon)	Visualizzazione	Visualizzazione in Designer
Canada (Centrale)	Visualizzazione	Visualizzazione in Designer
Sud America (San Paolo)	Visualizzazione	Visualizzazione in Designer
Europa (Stoccolma)	Visualizzazione	Visualizzazione in Designer
Europa (Irlanda)	Visualizzazione	Visualizzazione in Designer
Europa (Londra)	Visualizzazione	Visualizzazione in Designer
Europa (Parigi)	Visualizzazione	Visualizzazione in Designer
Europa (Francoforte)	Visualizzazione	Visualizzazione in Designer
Medio Oriente (Bahrein)	Visualizzazione	Visualizzazione in Designer
Medio Oriente (Emirati Arabi Uniti)	Visualizzazione	Visualizzazione in Designer
Israele (Tel Aviv)	Visualizzazione	Visualizzazione in Designer
Africa (Città del Capo)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Tokyo)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Hong Kong)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Seoul)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Singapore)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Sydney)	Visualizzazione	Visualizzazione in Designer
Asia Pacifico (Mumbai)	Visualizzazione	Visualizzazione in Designer
Cina (Pechino)	Visualizzazione	Visualizzazione in Designer
Cina (Ningxia)	Visualizzazione	Visualizzazione in Designer
AWS GovCloud (Stati Uniti occidentali)	Visualizzazione	Visualizzazione in Designer
AWS GovCloud (Stati Uniti orientali)	Visualizzazione	Visualizzazione in Designer

Nella pagina Create Stack (Crea stack) scegliere Next (Avanti).

Aggiunta di dettagli relativi allo stack consumer di flussi Neptune che verranno creati

La pagina Specify Stack Details (Specifica dettagli stack) fornisce proprietà e parametri che è possibile utilizzare per controllare la configurazione dell'applicazione:

Nome dello stack: il nome del nuovo AWS CloudFormation stack che stai creando. In genere è possibile utilizzare il valore predefinito NeptuneStreamPoller.

In Parametri, fornire quanto segue:

Configurazione di rete per il VPC in cui viene eseguita l'applicazione consumer di flussi

• VPC: specifica il nome del VPC in cui verrà eseguita la funzione Lambda di polling.

• SubnetIDs: sottoreti in cui viene stabilita un'interfaccia di rete. Aggiungere le sottoreti corrispondenti al cluster Neptune.

• SecurityGroupIds: specifica gli ID dei gruppi di sicurezza che concedono l'accesso in ingresso in scrittura al cluster database Neptune di origine.

• RouteTableIds: necessario per creare un endpoint Amazon DynamoDB nel VPC Neptune, se non è presente. È necessario fornire un elenco separato da virgole di ID tabella di routing associati alle sottoreti.

• CreateDDBVPCEndPoint: valore booleano il cui valore predefinito è true, che indica se è necessario creare o meno un endpoint VPC Dynamo DB. È necessario modificarlo e impostarlo su false solo se è già stato creato un endpoint DynamoDB nel VPC.

• CreateMonitoringEndPoint: valore booleano il cui valore predefinito è true, che indica se è necessario creare o meno un endpoint VPC di monitoraggio. È necessario modificarlo in false solo se è già stato creato un endpoint di monitoraggio nel VPC.

Polling di flussi

• ApplicationName: in genere è possibile lasciare questo valore impostato sul valore predefinito (NeptuneStream). Se si utilizza un nome diverso, deve essere univoco.

• LambdaMemorySize: consente di impostare le dimensioni della memoria disponibili per la funzione Lambda dello strumento di polling. Il valore predefinito è 2.048 megabyte.

• LambdaRuntime: linguaggio utilizzato nella funzione Lambda che recupera gli elementi dal flusso Neptune. Può essere impostato su python3.9 o su java8.

• LambdaS3Bucket: bucket Amazon S3 che contiene artefatti del codice Lambda. Lasciare questo parametro vuoto, a meno che non si utilizzi una funzione di polling Lambda personalizzata che viene caricata da un bucket Amazon S3 diverso.

• LambdaS3Key: chiave Amazon S3 che corrisponde agli artefatti del codice Lambda. Lasciare questo parametro vuoto, a meno che non si utilizzi una funzione di polling Lambda personalizzata.

• LambdaLoggingLevel: in generale, lasciare il valore predefinito, INFO.

• ManagedPolicies: elenca le policy gestite da utilizzare per l'esecuzione della funzione Lambda. In generale, lasciare vuoto a meno che non si utilizzi una funzione di polling Lambda personalizzata.

• StreamRecordsHandler: in generale, lascia vuoto a meno che non utilizzi un gestore personalizzato per i record nei flussi Neptune.

• StreamRecordsBatchSize: numero massimo di registri da recuperare dal flusso. È possibile utilizzare questo parametro per ottimizzare le prestazioni. Il valore predefinito (5000) è un buon punto di partenza. Il massimo consentito è 10.000. Più alto è il numero, meno chiamate di rete sono necessarie per leggere i record dal flusso, ma maggiore è la memoria necessaria per elaborare i record. Valori più bassi di questo parametro comportano una minore velocità di trasmissione effettiva.

• MaxPollingWaitTime: tempo di attesa massimo tra due polling (in secondi). Determina la frequenza con cui viene richiamato lo strumento di polling Lambda per il polling dei flussi Neptune. Impostare questo valore su 0 per il polling continuo. Il valore massimo è di 3.600 secondi (1 ora). Il valore predefinito (60 secondi) è un buon punto di partenza, a seconda della velocità con cui cambiano i dati del grafico.

• MaxPollingInterval: periodo massimo di polling continuo (in secondi). Consente di impostare un timeout per la funzione di polling Lambda. Il valore deve essere compreso tra 5 e 900 secondi. Il valore predefinito (600 secondi) è un buon punto di partenza.

• StepFunctionFallbackPeriod— Il numero di unità di cui step-function-fallback-period attendere il poller, dopodiché la funzione step viene richiamata tramite Amazon CloudWatch Events per il ripristino in caso di errore. Il valore predefinito (5 minuti) è un buon punto di partenza.

• StepFunctionFallbackPeriodUnit: unità di tempo utilizzate per misurare il periodo StepFunctionFallbackPeriodUnit precedente (minutes, hours o days). Il valore predefinito (minutes) è generalmente sufficiente.

Flusso Neptune

• NeptuneStreamEndpoint: (obbligatorio) endpoint del flusso di origine Neptune. Può assumere uno dei due formati seguenti:

  • https://your DB cluster:port/propertygraph/stream (o il relativo alias, https://your DB cluster:port/pg/stream).

  • https://your DB cluster:port/sparql/stream.

• Neptune Query Engine: scegliere Gremlin, openCypher o SPARQL.

• IAMAuthEnabledOnSourceStream: se il cluster database Neptune utilizza l'autenticazione IAM, impostare questo parametro su true.

• StreamDBClusterResourceId: se il cluster database Neptune utilizza l'autenticazione IAM, impostare questo parametro sull'ID risorsa del cluster. L'ID risorsa non è lo stesso dell'ID cluster. Invece, assume il formato: cluster- seguito da 28 caratteri alfanumerici. Può essere trovato in Dettagli del cluster nella console Neptune.

Cluster database Neptune di destinazione

• TargetNeptuneClusterEndpoint: endpoint (solo nome host) del cluster di backup di destinazione.

  Notare che se si specifica TargetNeptuneClusterEndpoint, non si può specificare TargetSPARQLUpdateEndpoint.

• TargetNeptuneClusterPort: numero di porta per il cluster di destinazione.

  Notare che se si specifica TargetSPARQLUpdateEndpoint, l'impostazione di TargetNeptuneClusterPort viene ignorata.

• IAMAuthEnabledOnTargetCluster: impostare su true se l'autenticazione IAM deve essere abilitata sul cluster di destinazione.

• TargetAWSRegion— La AWS regione del cluster di backup di destinazione, ad esempious-east-1). È necessario fornire questo parametro solo quando la AWS regione del cluster di backup di destinazione è diversa dalla regione del cluster di origine Neptune, come nel caso della replica tra regioni. Se le regioni di origine e di destinazione coincidono, questo parametro è facoltativo.

  Nota che se il TargetAWSRegion valore non è una AWS regione valida supportata da Neptune, il processo fallisce.

• TargetNeptuneDBClusterResourceId: (facoltativo) è necessario solo quando l'autenticazione IAM è abilitata nel cluster database di destinazione. Impostare sull'ID risorsa del cluster di destinazione.

• SPARQLTripleOnlyMode: flag booleano che determina se è abilitata la modalità solo tripla. In modalità solo tripla, non è disponibile la replica del grafo nominato. Il valore predefinito è false.

• TargetSPARQLUpdateEndpoint: URL dell'endpoint di destinazione per l'aggiornamento SPARQL, ad esempio https://abc.com/xyz. Questo endpoint può essere qualsiasi archivio SPARQL che supporti quadruple o triple.

  Notare che se si specifica TargetSPARQLUpdateEndpoint, non è possibile specificare anche TargetNeptuneClusterEndpoint e l'impostazione di TargetNeptuneClusterPort viene ignorata.

• BlockSparqlReplicationOnBlankNode — Bandiera booleana che, se impostata sutrue, interrompe la replica dei dati BlankNode in SPARQL (RDF). Il valore predefinito è false.

Allarme

• Required to create Cloud watch Alarm— Impostalo su true se vuoi creare un CloudWatch allarme per il nuovo stack.

• SNS Topic ARN for Cloudwatch Alarm Notifications— L'argomento SNS ARN in CloudWatch cui devono essere inviate le notifiche di allarme (necessario solo se gli allarmi sono abilitati).

• Email for Alarm Notifications: indirizzo e-mail a cui devono essere inviate le notifiche di allarme (necessario solo se gli allarmi sono abilitati).

Per la destinazione della notifica di allarme, è possibile aggiungere solo SNS, solo e-mail o sia SNS che e-mail.

Esegui il modello AWS CloudFormation

A questo punto è possibile completare il processo di provisioning di un'istanza dell'applicazione consumer di flussi Neptune come indicato di seguito:

1. Nella AWS CloudFormation pagina Specificare i dettagli dello stack, scegli Avanti.

2. Nella pagina Opzioni, scegli Avanti.

3. Nella pagina Revisione, seleziona la prima casella di controllo per accettare la creazione delle risorse IAM da parte di AWS CloudFormation . Seleziona la seconda casella di controllo per confermare CAPABILITY_AUTO_EXPAND per il nuovo stack.

   Nota

   CAPABILITY_AUTO_EXPAND conferma in modo esplicito che, durante la creazione dello stack, le macro verranno ampliate senza revisione preventiva. Gli utenti spesso creano un set di modifiche da un modello elaborato, quindi le modifiche apportate dalle macro possono essere riesaminate prima dell’effettiva creazione dello stack. Per ulteriori informazioni, consulta l' AWS CloudFormation CreateStackAPI nell'AWS CloudFormation API Reference.

   Quindi, scegli Crea.

Per aggiornare lo strumento per il polling dei flussi con gli ultimi artefatti Lambda

Per aggiornare lo strumento per il polling dei flussi con gli ultimi artefatti Lambda, segui questa procedura:

1. In AWS Management Console, accedi AWS CloudFormation e seleziona lo AWS CloudFormation stack principale.

2. Seleziona l'opzione Aggiorna per lo stack.

3. Seleziona Sostituisci modello corrente.

4. Per l'origine del modello, scegli URL di Amazon S3 e immetti l'URL S3 seguente:

   https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_neptune.json

5. Seleziona Avanti senza modificare alcun AWS CloudFormation parametro.

6. Scegliere Update Stack (Aggiorna stack).

Lo stack ora aggiornerà gli artefatti Lambda con quelli più recenti.