Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
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.
Argomenti
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.
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 sufalse
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 infalse
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 supython3.9
o sujava8
.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 periodoStepFunctionFallbackPeriodUnit
precedente (minutes
,hours
odays
). Il valore predefinito (minutes
) è generalmente sufficiente.
Flusso Neptune
-
NeptuneStreamEndpoint
: (obbligatorio) endpoint del flusso di origine Neptune. Può assumere uno dei due formati seguenti:https://
(o il relativo alias,your DB cluster
:port
/propertygraph/streamhttps://
).your DB cluster
:port
/pg/streamhttps://
.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 sutrue
.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ò specificareTargetSPARQLUpdateEndpoint
. -
TargetNeptuneClusterPort
: numero di porta per il cluster di destinazione.Notare che se si specifica
TargetSPARQLUpdateEndpoint
, l'impostazione diTargetNeptuneClusterPort
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 esempiohttps://abc.com/xyz
. Questo endpoint può essere qualsiasi archivio SPARQL che supporti quadruple o triple.Notare che se si specifica
TargetSPARQLUpdateEndpoint
, non è possibile specificare ancheTargetNeptuneClusterEndpoint
e l'impostazione diTargetNeptuneClusterPort
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 sutrue
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:
Nella AWS CloudFormation pagina Specificare i dettagli dello stack, scegli Avanti.
Nella pagina Opzioni, scegli Avanti.
-
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:
In AWS Management Console, accedi AWS CloudFormation e seleziona lo AWS CloudFormation stack principale.
Seleziona l'opzione Aggiorna per lo stack.
Seleziona Sostituisci modello corrente.
-
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
Seleziona Avanti senza modificare alcun AWS CloudFormation parametro.
Scegliere Update Stack (Aggiorna stack).
Lo stack ora aggiornerà gli artefatti Lambda con quelli più recenti.