Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Exportación nativa de datos RDF

La API de exportación de Neptune le permite exportar datos de su base de datos de Neptune a Amazon S3. Puede exportar los datos RDF en N-Triples formato o. N-Quads

Cómo funciona la exportación nativa

La exportación nativa se ejecuta en la instancia de escritura de su clúster de Neptune y escribe los datos exportados en Amazon S3 mediante cargas multiparte. Dado que la exportación utiliza los recursos informáticos de la instancia de escritura, recomendamos encarecidamente ejecutar las exportaciones en un clúster clonado para evitar que afecten a las cargas de trabajo de producción. Consulta las recomendaciones para obtener más información.

Rendimiento de exportación

El rendimiento de exportación se escala de forma aproximadamente lineal con un tamaño de instancia de hastar7i.16xlarge. Como estimación de planificación conservadora, espere aproximadamente 50 000 declaraciones por segundo por CPU virtual.

Utilice esta fórmula para estimar la duración de la exportación:

export_seconds = total_statements / (vCPUs × 50,000)

El rendimiento real depende de las características del conjunto de datos, incluida la cardinalidad de los predicados, la complejidad de las declaraciones y el tamaño del clúster.

Requisitos previos

Antes de usar la API de exportación, debes:

Recomendaciones

Recomendamos encarecidamente ejecutar la operación de exportación en un clúster clonado sin read/write cargas de trabajo para evitar que esto afecte al rendimiento de la producción.

Para obtener una relación precio-rendimiento óptima, recomendamos utilizar instancias de 16 veces más grandes para las operaciones de exportación. Este tipo de instancia proporciona:

Permisos de IAM

La función de exportación implica dos funciones de IAM independientes:

Permisos de llamadas (acciones de acceso a los datos de Neptune)

El director de IAM que llama a la API de exportación debe incluir las siguientes acciones de acceso a los datos de Neptune en su política de IAM:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "AllowNeptuneExportActions",
      "Effect": "Allow",
      "Action": [
        "neptune-db:StartExportJob",
        "neptune-db:GetExportJobStatus",
        "neptune-db:ListExportJobs",
        "neptune-db:CancelExportJob"
      ],
      "Resource": "arn:aws:neptune-db:us-east-1:123456789012:cluster-resource-id/*"
    }
  ]
}

Para obtener más información, consulte Uso de las declaraciones de política de acceso a los datos de IAM.

Permisos de rol de acceso a S3

La función de IAM transferida en el parámetro de iamRoleArn solicitud debe estar asociada a su clúster de Neptune y debe conceder a Neptune permiso para escribir en el bucket de S3 de destino. Para ver los pasos para crear un rol de IAM y asociarlo a su clúster, consulte Crear un rol de IAM para permitir que Neptune acceda a Amazon S3.

Adjunte la siguiente política de permisos a la función de acceso de S3:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "AllowS3WriteForNeptuneExport",
      "Effect": "Allow",
      "Action": [
        "s3:ListBucket",
        "s3:GetObject",
        "s3:PutObject",
        "s3:AbortMultipartUpload",
        "s3:GetBucketPublicAccessBlock"
      ],
      "Resource": [
        "arn:aws:s3:::amzn-s3-demo-bucket",
        "arn:aws:s3:::amzn-s3-demo-bucket/*"
      ]
    }
  ]
}

Permisos de KMS opcionales

Si especificas un kmsKeyIdentifier en la solicitud de exportación, agrega los siguientes permisos al rol de acceso a S3:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "AllowKMSForNeptuneExport",
      "Effect": "Allow",
      "Action": [
        "kms:Decrypt",
        "kms:Encrypt",
        "kms:GenerateDataKey"
      ],
      "Resource": "arn:aws:kms:us-east-1:123456789012:key/key-id"
    }
  ]
}

Punto final de exportación

Para exportar datos, debe enviar solicitudes HTTP al https://your-neptune-endpoint:port/export punto final.

Sintaxis de la solicitud de exportación

POST https://your-neptune-endpoint:port/export

Encabezados de solicitudes

Cuerpo de la solicitud

{
  "destination": "string",
  "format": "string",
  "iamRoleArn": "string",
  "region": "string",
  "compression": "string",
  "kmsKeyIdentifier": "string",
  "exportFilter": {
    "namedGraphUris": ["string"]
  }
}

Parámetros de solicitud

Sintaxis de la respuesta

{
  "status": "string",
  "payload": {
    "exportId": "string"
  }
}

Punto final de estado de exportación

Para comprobar el estado de una tarea de exportación, debe enviar una solicitud HTTP GET al punto final de exportación con el ID de exportación.

GET https://your-neptune-endpoint:port/export?exportId=export-id

Parámetros de solicitud

Sintaxis de la respuesta

{
  "status": "string",
  "payload": {
    "exportId": "string",
    "destination": "string",
    "status": "string",
    "statusReason": "string",
    "format": "string",
    "iamRoleArn": "string",
    "kmsKeyIdentifier": "string",
    "exportFilter": {
      "namedGraphUris": ["string"]
    },
    "exportTaskDetails": {
      "timeElapsedSeconds": number,
      "startTime": number,
      "numRecordsWritten": number,
      "progressPercentage": number
    }
  }
}

Punto final de exportación de la lista

Para enumerar todas las tareas de exportación, envía una solicitud HTTP GET al punto final de exportación.

GET https://your-neptune-endpoint:port/export

Sintaxis de la respuesta

{
  "status": "string",
  "payload": [
    "string"
  ]
}

Cancela el punto final de exportación

Para cancelar una tarea de exportación, envía una solicitud HTTP DELETE al punto final de exportación con el ID de exportación.

DELETE https://your-neptune-endpoint:port/export?exportId=export-id

Parámetros de solicitud

Sintaxis de la respuesta

{
  "status": "string",
  "payload": {
    "message": "string"
  }
}

Formato de salida de exportación

Estructura de directorios de S3

Los datos exportados se organizan en su bucket de S3 de la siguiente manera:

s3://your-bucket/export-id/
├── data/
│   ├── part-00000.nt
│   ├── part-00001.nt
│   └── ...
└── export_status.json

Respuestas de error

Códigos de error comunes

Ejemplo de respuesta de error

{
  "code": "BadRequestException",
  "requestId": "request-id", 
  "message": "Export already in progress with ID 'existing-id'. Please wait or cancel it first.",
  "detailedMessage": "Detailed error description"
}

Ejemplos

Iniciar una exportación

curl -X POST https://your-cluster-endpoint:8182/export \
  -H "Content-Type: application/json" \
  -d '{
    "destination": "s3://my-bucket/exports/",
    "format": "ntriples", 
    "iamRoleArn": "arn:aws:iam::123456789012:role/neptune-export-role",
    "region": "us-west-2"
  }'

Iniciar una exportación filtrada (gráficos con nombre)

curl -X POST https://your-cluster-endpoint:8182/export \
  -H "Content-Type: application/json" \
  -d '{
    "destination": "s3://my-bucket/exports/",
    "format": "nquads",
    "iamRoleArn": "arn:aws:iam::123456789012:role/neptune-export-role",
    "region": "us-west-2",
    "exportFilter": {
      "namedGraphUris": [
        "http://example.com/graph1",
        "http://example.com/graph2"
      ]
    }
  }'

Compruebe el estado de la exportación

curl -X GET "https://your-cluster-endpoint:8182/export?exportId=<id>"

Cancelar una exportación

curl -X DELETE "https://your-cluster-endpoint:8182/export?exportId=<id>"

Limitaciones

La exportación nativa tiene las siguientes limitaciones: