Esempio: caricamento di dati in un'istanza database Neptune

Accedi a AWS Management Console e apri la VPC console Amazon all'indirizzo https://console.aws.amazon.com/vpc/.

Nel riquadro di navigazione a sinistra, scegli Endpoints (Endpoint).

Scegliere Create Endpoint (Crea endpoint).

Scegli il Service Name (Nome servizio) com.amazonaws.region.s3.

Scegli VPC quella che contiene la tua istanza DB Neptune.

Selezionare la casella di controllo accanto alle tabelle di routing associate alle sottoreti correlate al proprio cluster. Se si dispone di una sola tabella di routing, è necessario selezionare la casella corrispondente.

Scegliere Create Endpoint (Crea endpoint).

Copiare i file di dati in un bucket Amazon S3. Il bucket S3 deve trovarsi nella stessa AWS regione del cluster che carica i dati.

È possibile utilizzare il seguente AWS CLI comando per copiare i file nel bucket.

aws s3 cp data-file-name s3://bucket-name/object-key-name

In alternativa, puoi utilizzare il AWS Management Console per caricare file nel bucket S3. Apri la console Amazon S3 all'indirizzo https://console.aws.amazon.com/s3/e scegli un bucket. Nell'angolo superiore sinistro, scegli Upload (Carica) per caricare i file.

Da una finestra della riga di comando, inserisci quanto segue per eseguire il loader Neptune, utilizzando i valori corretti per l'endpoint, il percorso, il formato e il ruolo di Amazon S3. IAM ARN

Il format parametro può essere uno dei seguenti valori: csv for Gremlin, for, or,, e opencypher foropenCypher. ntriples nquads turtle rdfxml RDF Per informazioni sugli altri parametri, vedi Comando dello strumento di caricamento Neptune.

Per informazioni su come trovare il nome host dell'istanza database Neptune, consulta la sezione Connessione agli endpoint Amazon Neptune.

Il parametro della regione deve corrispondere alla regione del cluster e del bucket S3.

Amazon Neptune è disponibile nelle seguenti regioni: AWS

curl -X POST \
    -H 'Content-Type: application/json' \
    https://your-neptune-endpoint:port/loader -d '
    {
      "source" : "s3://bucket-name/object-key-name",
      "format" : "format",
      "iamRoleArn" : "arn:aws:iam::account-id:role/role-name",
      "region" : "region",
      "failOnError" : "FALSE",
      "parallelism" : "MEDIUM",
      "updateSingleCardinalityProperties" : "FALSE",
      "queueRequest" : "TRUE",
      "dependencies" : ["load_A_id", "load_B_id"]
    }'

Per informazioni sulla creazione e l'associazione di un IAM ruolo a un cluster Neptune, vedere. Prerequisiti: IAM ruolo e accesso ad Amazon S3

Lo strumento di caricamento Neptune restituisce un oggetto id del processo che consente di controllare lo stato o di annullare il processo di caricamento, ad esempio:

{
    "status" : "200 OK",
    "payload" : {
        "loadId" : "ef478d76-d9da-4d94-8ff1-08d9d4863aa5"
    }
}

Inserisci il comando seguente per ottenere lo stato del caricamento con il valore loadId della Fase 3:

curl -G 'https://your-neptune-endpoint:port/loader/ef478d76-d9da-4d94-8ff1-08d9d4863aa5'

Se lo stato del caricamento elenca un errore, è possibile richiedere uno stato più dettagliato e un elenco degli errori. Per maggiori informazioni ed esempi, consulta Neptune Loader Get-Status API.

(Facoltativo) Annullare il processo Load.

inserisci il comando seguente per eseguire un Delete del processo dello strumento di caricamento con il valore id del processo della Fase 3:

curl -X DELETE 'https://your-neptune-endpoint:port/loader/ef478d76-d9da-4d94-8ff1-08d9d4863aa5'

Il DELETE comando restituisce il HTTP codice 200 OK dopo l'annullamento riuscito.

I dati provenienti dai file dal processo di caricamento terminato non vengono ripristinati. I dati rimangono nell'istanza database Neptune.