Exemple : chargement de données dans une instance de base de données Neptune

Connectez-vous à la console Amazon VPC AWS Management Console et ouvrez-la à l'adresse. https://console.aws.amazon.com/vpc/

Dans le panneau de navigation de gauche, sélectionnez Points de terminaison.

Choisissez Créer un point de terminaison.

Pour Nom du service, choisissez com.amazonaws.region.s3.

Choisissez le VPC qui contient votre instance de base de données Neptune.

Cochez la case en regard des tables de routage associées aux sous-réseaux liés à votre cluster. Si vous n'avez qu'une seule table de routage, vous devez cocher cette case.

Choisissez Créer un point de terminaison.

Copiez les fichiers de données dans un compartiment Amazon S3. Le compartiment S3 doit se trouver dans la même AWS région que le cluster qui charge les données.

Vous pouvez utiliser la AWS CLI commande suivante pour copier les fichiers dans le compartiment.

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

Vous pouvez également utiliser le AWS Management Console pour télécharger des fichiers dans le compartiment S3. Ouvrez la console Amazon S3 à https://console.aws.amazon.com/s3/l'adresse et choisissez un compartiment. Dans le coin supérieur gauche, choisissez Upload (Charger) pour charger les fichiers.

Dans une fenêtre de ligne de commande, entrez ce qui suit pour exécuter le chargeur Neptune en utilisant les valeurs correctes pour votre point de terminaison, le chemin Amazon S3, le format et l'ARN du rôle IAM.

Le paramètre format peut avoir l'une des valeurs suivantes : csv pour Gremlin, opencypher pour openCypher ou ntriples, nquads, turtle, et rdfxml pour RDF. Pour plus d'informations sur les autres paramètres, consultez Commande de chargeur Neptune.

Consultez la section Connexion aux points de terminaison Amazon Neptune pour découvrir comment trouver le nom d'hôte de votre instance de base de données Neptune.

Le paramètre de région doit correspondre à la région du cluster et au compartiment S3.

Amazon Neptune est disponible dans les régions suivantes : 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"]
    }'

Pour plus d'informations sur la création et l'association d'un rôle IAM à un cluster Neptune, consultez Prérequis : rôle IAM et accès à Amazon S3.

Le chargeur Neptune renvoie un id de tâche qui vous permet de vérifier le statut ou d'annuler le processus de chargement, par exemple :

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

Saisissez la commande suivante pour obtenir le statut du chargement avec le paramètre loadId de l'étape 3 :

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

Si le statut du chargement signale une erreur, vous pouvez demander un statut plus détaillé et une liste des erreurs. Pour plus d’informations et d’exemples, consultez API Neptune Loader Get-Status .

(Facultatif) Annulez la tâche Load.

Saisissez la commande suivante pour supprimer (Delete) la tâche de chargement (loader) avec l'id de tâche de l'étape 3 :

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

La commande DELETE renvoie le code HTTP 200 OK lorsque l'annulation a réussi.

Les données des fichiers de la tâche de chargement qui ont fini de se charger ne sont pas annulées. Les données restent dans l'instance de base de données Neptune.