Uso de un cliente Java para conectarse a una instancia de base de datos de Neptune

Instale Apache Maven en su instancia. EC2 En primer lugar, escriba lo siguiente para añadir un repositorio con un paquete de Maven:

sudo wget https://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo

Escriba lo siguiente para establecer el número de versión de los paquetes:

sudo sed -i s/\$releasever/6/g /etc/yum.repos.d/epel-apache-maven.repo

A continuación, use el comando yum para instalar Maven:

sudo yum install -y apache-maven

Instale Java. Las bibliotecas de Gremlin necesitan Java 8 u 11. Puede instalar Java 11 como se indica a continuación:

Defina Java 11 como el tiempo de ejecución predeterminado de la EC2 instancia: introduzca lo siguiente para establecer Java 8 como el tiempo de ejecución predeterminado de la EC2 instancia:

sudo /usr/sbin/alternatives --config java

Cuando se le solicite, escriba el número para Java 11.

Cree un nuevo directorio llamado gremlinjava:

mkdir gremlinjava
cd gremlinjava

En el directorio gremlinjava, cree un archivo pom.xml y, a continuación, ábralo en un editor de texto:

nano pom.xml

Copie lo siguiente en el archivo pom.xml y guárdelo:

<project xmlns="https://maven.apache.org/POM/4.0.0"
         xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="https://maven.apache.org/POM/4.0.0 https://maven.apache.org/maven-v4_0_0.xsd">
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.amazonaws</groupId>
  <artifactId>GremlinExample</artifactId>
  <packaging>jar</packaging>
  <version>1.0-SNAPSHOT</version>
  <name>GremlinExample</name>
  <url>https://maven.apache.org</url>
  <dependencies>
    <dependency>
      <groupId>org.apache.tinkerpop</groupId>
      <artifactId>gremlin-driver</artifactId>
      <version>3.6.5</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.tinkerpop/gremlin-groovy
      (Not needed for TinkerPop version 3.5.2 and up)
    <dependency>
      <groupId>org.apache.tinkerpop</groupId>
      <artifactId>gremlin-groovy</artifactId>
      <version>3.6.5</version>
    </dependency> -->
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-jdk14</artifactId>
      <version>1.7.25</version>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>2.5.1</version>
        <configuration>
          <source>11</source>
          <target>11</target>
        </configuration>
      </plugin>
        <plugin>
          <groupId>org.codehaus.mojo</groupId>
          <artifactId>exec-maven-plugin</artifactId>
          <version>1.3</version>
          <configuration>
            <executable>java</executable>
            <arguments>
              <argument>-classpath</argument>
              <classpath/>
              <argument>com.amazonaws.App</argument>
            </arguments>
            <mainClass>com.amazonaws.App</mainClass>
            <complianceLevel>1.11</complianceLevel>
            <killAfter>-1</killAfter>
          </configuration>
        </plugin>
    </plugins>
  </build>
</project>

Escriba lo siguiente en la línea de comandos a fin de crear subdirectorios para el código fuente de ejemplo (src/main/java/com/amazonaws/):

mkdir -p src/main/java/com/amazonaws/

En el directorio src/main/java/com/amazonaws/, cree un archivo llamado App.java y, a continuación, ábralo en un editor de texto.

nano src/main/java/com/amazonaws/App.java

Copie lo siguiente en el archivo App.java. Reemplazar your-neptune-endpoint con la dirección de su instancia de base de datos Neptune. No incluya el prefijo https:// en el método addContactPoint.

package com.amazonaws;
import org.apache.tinkerpop.gremlin.driver.Cluster;
import org.apache.tinkerpop.gremlin.driver.Client;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
import static org.apache.tinkerpop.gremlin.process.traversal.AnonymousTraversalSource.traversal;
import org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteConnection;
import org.apache.tinkerpop.gremlin.structure.T;

public class App
{
  public static void main( String[] args )
  {
    Cluster.Builder builder = Cluster.build();
    builder.addContactPoint("your-neptune-endpoint");
    builder.port(8182);
    builder.enableSsl(true);

    Cluster cluster = builder.create();

    GraphTraversalSource g = traversal().withRemote(DriverRemoteConnection.using(cluster));

    // Add a vertex.
    // Note that a Gremlin terminal step, e.g. iterate(), is required to make a request to the remote server.
    // The full list of Gremlin terminal steps is at https://tinkerpop.apache.org/docs/current/reference/#terminal-steps
    g.addV("Person").property("Name", "Justin").iterate();

    // Add a vertex with a user-supplied ID.
    g.addV("Custom Label").property(T.id, "CustomId1").property("name", "Custom id vertex 1").iterate();
    g.addV("Custom Label").property(T.id, "CustomId2").property("name", "Custom id vertex 2").iterate();

    g.addE("Edge Label").from(__.V("CustomId1")).to(__.V("CustomId2")).iterate();

    // This gets the vertices, only.
    GraphTraversal t = g.V().limit(3).elementMap();

    t.forEachRemaining(
      e ->  System.out.println(t.toList())
    );

    cluster.close();
  }
}

Si necesita ayuda para conectarse a Neptune conSSL/TLS(obligatorio), consulte. SSL/configuración TLS

Compile y ejecute el ejemplo usando el siguiente comando Maven:

mvn compile exec:exec

Descargue e instale keytool de Oracle. Esto facilitará mucho la configuración del almacén de claves local.

Descargue el certificado de SFSRootCAG2.pem CA (el Gremlin Java SDK requiere un certificado para verificar el certificado remoto):

wget https://www.amazontrust.com/repository/SFSRootCAG2.pem

Cree un almacén de claves en uno de los dos formatos. JKS PKCS12 En este ejemplo se utiliza JKS. Responda las preguntas que aparecen a continuación cuando se le pida. La contraseña que cree aquí la necesitará más adelante:

keytool -genkey -alias (host name) -keyalg RSA -keystore server.jks

Importe el archivo SFSRootCAG2.pem que descargó al almacén de claves recién creado:

keytool -import -keystore server.jks -file .pem

Configure el objeto Cluster mediante programación:

Cluster cluster = Cluster.build("(your neptune endpoint)")
                         .port(8182)
                         .enableSSL(true)
                         .keyStore(‘server.jks’)
                         .keyStorePassword("(the password from step 2)")
                         .create();

Si lo desea, puede hacer lo mismo en un archivo de configuración, y también con la consola de Gremlin:

hosts: [(your neptune endpoint)]
port: 8182
connectionPool: { enableSsl: true, keyStore: server.jks, keyStorePassword: (the password from step 2) }
serializer: { className: org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1, config: { serializeResultToString: true }}