Utilizzo AWS CloudFormation per impostare la Neptune-to-Neptune replica con l'applicazione Streams Consumer

VPC— Fornisci il nome del VPC luogo 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— Fornisci i gruppi IDs di sicurezza che garantiscono l'accesso in scrittura in entrata al cluster Neptune DB di origine.

RouteTableIds— È necessario per creare un endpoint Amazon DynamoDB nel tuo VPC Neptune, se non ne hai già uno. È necessario fornire un elenco separato da virgole della tabella di routing associata alle sottoreti. IDs

CreateDDBVPCEndPoint— Un valore booleano predefinito sutrue, che indica se è necessario creare o meno un endpoint Dynamo DB. VPC Devi cambiarlo solo false se hai già creato un endpoint DynamoDB nel tuo. VPC

CreateMonitoringEndPoint— Un valore booleano predefinito sutrue, che indica se è necessario creare o meno un endpoint di monitoraggio. VPC Devi modificarlo solo false se hai già creato un endpoint di monitoraggio nel tuo. VPC

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.

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

Neptune Query Engine— Scegli Gremlin, openCypher o. SPARQL

IAMAuthEnabledOnSourceStream— Se il cluster Neptune DB IAM utilizza l'autenticazione, imposta questo parametro su. true

StreamDBClusterResourceId— Se il cluster Neptune DB IAM utilizza l'autenticazione, imposta questo parametro sull'ID della 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.

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— Impostato su true se IAM l'autenticazione 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 IAM l'autenticazione è abilitata sul cluster DB 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'SPARQLaggiornamento, ad esempiohttps://abc.com/xyz. Questo endpoint può essere qualsiasi SPARQL negozio che supporti le versioni quadruple o triple.

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

BlockSparqlReplicationOnBlankNode — Flag booleano che, se impostato sutrue, interrompe la replica dei dati in (). BlankNode SPARQL RDF Il valore predefinito è false.

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'SNSargomento ARN in cui devono essere inviate le notifiche di CloudWatch 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).