Étape 2 : Tester de la connectivité au registre - Amazon Quantum Ledger Database (Amazon QLDB)

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Étape 2 : Tester de la connectivité au registre

Au cours de cette étape, vous devez vérifier que vous pouvez vous connecter auvehicle-registration registre dans Amazon QLDB à l'aide du point de terminaison de l'API de données transactionnelles.

Pour tester la connectivité au registre

  1. Consultez le programme suivant (ConnectToLedger.java), qui crée une connexion de session de données auvehicle-registration registre.

    2.x
    /*
 * Copyright 2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: MIT-0
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of this
 * software and associated documentation files (the "Software"), to deal in the Software
 * without restriction, including without limitation the rights to use, copy, modify,
 * merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
 * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

package software.amazon.qldb.tutorial;

import java.net.URI;
import java.net.URISyntaxException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.services.qldbsession.QldbSessionClient;
import software.amazon.awssdk.services.qldbsession.QldbSessionClientBuilder;
import software.amazon.qldb.QldbDriver;
import software.amazon.qldb.RetryPolicy;

/**
 * Connect to a session for a given ledger using default settings.
 * <p>
 * This code expects that you have AWS credentials setup per:
 * http://docs.aws.amazon.com/java-sdk/latest/developer-guide/setup-credentials.html
 */
public final class ConnectToLedger {
    public static final Logger log = LoggerFactory.getLogger(ConnectToLedger.class);
    public static AwsCredentialsProvider credentialsProvider;
    public static String endpoint = null;
    public static String ledgerName = Constants.LEDGER_NAME;
    public static String region = null;
    public static QldbDriver driver;

    private ConnectToLedger() {
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @param retryAttempts How many times the transaction will be retried in
     * case of a retryable issue happens like Optimistic Concurrency Control exception,
     * server side failures or network issues.
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver createQldbDriver(int retryAttempts) {
        QldbSessionClientBuilder builder = getAmazonQldbSessionClientBuilder();
        return QldbDriver.builder()
                             .ledger(ledgerName)
                             .transactionRetryPolicy(RetryPolicy
                                   .builder()
                                   .maxRetries(retryAttempts)
                                   .build())
                             .sessionClientBuilder(builder)
                             .build();
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver createQldbDriver() {
        QldbSessionClientBuilder builder = getAmazonQldbSessionClientBuilder();
        return QldbDriver.builder()
            .ledger(ledgerName)
            .transactionRetryPolicy(RetryPolicy.builder()
                                               .maxRetries(Constants.RETRY_LIMIT).build())
            .sessionClientBuilder(builder)
            .build();
    }

    /**
     * Creates a QldbSession builder that is passed to the QldbDriver to connect to the Ledger.
     *
     * @return An instance of the AmazonQLDBSessionClientBuilder
     */
    public static QldbSessionClientBuilder getAmazonQldbSessionClientBuilder() {
        QldbSessionClientBuilder builder = QldbSessionClient.builder();
        if (null != endpoint && null != region) {
            try {
                builder.endpointOverride(new URI(endpoint));
            } catch (URISyntaxException e) {
                throw new IllegalArgumentException(e);
            }
        }
        if (null != credentialsProvider) {
            builder.credentialsProvider(credentialsProvider);
        }
        return builder;
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver getDriver() {
        if (driver == null) {
            driver = createQldbDriver();
        }
        return driver;
    }


    public static void main(final String... args) {
        Iterable<String> tables = ConnectToLedger.getDriver().getTableNames();
        log.info("Existing tables in the ledger:");
        for (String table : tables) {
            log.info("- {} ", table);
        }
    }
}
    Note

    • Pour exécuter des opérations de données sur votre registre, vous devez créer une instance de laQldbDriver classe afin de vous connecter à un registre spécifique. Il s'agit d'un objet client différent deAmazonQLDB celui que vous avez utilisé à l'étape précédente pour créer le registre. Ce client précédent est uniquement utilisé pour exécuter les opérations d'API de gestion répertoriées dans leRéférence d'API Amazon QLDB.

    • Tout d'abord, créez unQldbDriver objet. Vous devez spécifier un nom de registre lorsque vous créez ce pilote.

      Vous pouvez ensuite utiliser laexecute méthode de ce pilote pour exécuter des instructions PartiQL.

    • Vous pouvez éventuellement spécifier un nombre maximum de nouvelles tentatives pour les exceptions de transaction. Laexecute méthode réessaie automatiquement les conflits de contrôle optimiste de la concurrence (OCC) et les autres exceptions transitoires courantes jusqu'à cette limite configurable. La valeur par défaut est 4.

      Si la transaction échoue toujours une fois la limite atteinte, le pilote lance l'exception. Pour en savoir plus, consultez Comprendre la stratégie de nouvelle tentative avec le pilote dans Amazon QLDB.

    1.x
    /*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: MIT-0
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of this
 * software and associated documentation files (the "Software"), to deal in the Software
 * without restriction, including without limitation the rights to use, copy, modify,
 * merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
 * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

package software.amazon.qldb.tutorial;

import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.qldbsession.AmazonQLDBSessionClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.qldb.PooledQldbDriver;
import software.amazon.qldb.QldbDriver;
import software.amazon.qldb.QldbSession;
import software.amazon.qldb.exceptions.QldbClientException;

/**
 * Connect to a session for a given ledger using default settings.
 * <p>
 * This code expects that you have AWS credentials setup per:
 * http://docs.aws.amazon.com/java-sdk/latest/developer-guide/setup-credentials.html
 */
public final class ConnectToLedger {
    public static final Logger log = LoggerFactory.getLogger(ConnectToLedger.class);
    public static AWSCredentialsProvider credentialsProvider;
    public static String endpoint = null;
    public static String ledgerName = Constants.LEDGER_NAME;
    public static String region = null;
    private static PooledQldbDriver driver;

    private ConnectToLedger() {
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static PooledQldbDriver createQldbDriver() {
        AmazonQLDBSessionClientBuilder builder = AmazonQLDBSessionClientBuilder.standard();
        if (null != endpoint && null != region) {
            builder.setEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, region));
        }
        if (null != credentialsProvider) {
            builder.setCredentials(credentialsProvider);
        }
        return PooledQldbDriver.builder()
                .withLedger(ledgerName)
                .withRetryLimit(Constants.RETRY_LIMIT)
                .withSessionClientBuilder(builder)
                .build();
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static PooledQldbDriver getDriver() {
        if (driver == null) {
            driver = createQldbDriver();
        }
        return driver;
    }

    /**
     * Connect to a ledger through a {@link QldbDriver}.
     *
     * @return {@link QldbSession}.
     */
    public static QldbSession createQldbSession() {
        return getDriver().getSession();
    }

    public static void main(final String... args) {
        try (QldbSession qldbSession = createQldbSession()) {
            log.info("Listing table names ");
            for (String tableName : qldbSession.getTableNames()) {
                log.info(tableName);
            }
        } catch (QldbClientException e) {
            log.error("Unable to create session.", e);
        }
    }
}
    Note

    • Pour exécuter des opérations de données sur votre registre, vous devez créer une instance de laQldbDriver classePooledQldbDriver or pour vous connecter à un registre spécifique. Il s'agit d'un objet client différent deAmazonQLDB celui que vous avez utilisé à l'étape précédente pour créer le registre. Ce client précédent est uniquement utilisé pour exécuter les opérations d'API de gestion répertoriées dans leRéférence d'API Amazon QLDB.

      Nous vous recommandons d'utiliser,PooledQldbDriver sauf si vous devez implémenter un pool de sessions personnalisé avecQldbDriver. La taille du pool par défaut pourPooledQldbDriver est le nombre maximum de connexions HTTP ouvertes autorisées par le client de session.

    • Tout d'abord, créez unPooledQldbDriver objet. Vous devez spécifier un nom de registre lorsque vous créez ce pilote.

      Vous pouvez ensuite utiliser laexecute méthode de ce pilote pour exécuter des instructions PartiQL. Vous pouvez également créer manuellement une session à partir de cet objet pilote groupé et utiliser laexecute méthode de la session. Une session représente une connexion unique avec le registre.

    • Vous pouvez éventuellement spécifier un nombre maximum de nouvelles tentatives pour les exceptions de transaction. Laexecute méthode réessaie automatiquement les conflits de contrôle optimiste de la concurrence (OCC) et les autres exceptions transitoires courantes jusqu'à cette limite configurable. La valeur par défaut est 4.

      Si la transaction échoue toujours une fois la limite atteinte, le pilote lance l'exception. Pour en savoir plus, consultez Comprendre la stratégie de nouvelle tentative avec le pilote dans Amazon QLDB.

  2. Compilez et exécutez leConnectToLedger.java programme pour tester la connectivité de votre session de données auvehicle-registration registre.

En annulant leRégion AWS

L'exemple d'application se connecte à QLDB par défautRégion AWS, que vous pouvez définir comme décrit dans l'étape préalableConfiguration de vosAWS informations d'identification et de votre région par défaut. Vous pouvez également modifier la région en modifiant les propriétés du générateur de client de session QLDB.

2.x

L'exemple de code suivant instancie un nouvelQldbSessionClientBuilder objet.

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.qldbsession.QldbSessionClientBuilder;

// This client builder will default to US East (Ohio)
QldbSessionClientBuilder builder = QldbSessionClient.builder()
    .region(Region.US_EAST_2);

Vous pouvez utiliserregion cette méthode pour exécuter votre code sur QLDB dans n'importe quelle région où il est disponible. Pour obtenir la liste complète, consultez les points de terminaison et quotas Amazon QLDB dans le Références générales AWS.

1.x

L'exemple de code suivant instancie un nouvelAmazonQLDBSessionClientBuilder objet.

import com.amazonaws.regions.Regions;
import com.amazonaws.services.qldbsession.AmazonQLDBSessionClientBuilder;

// This client builder will default to US East (Ohio)
AmazonQLDBSessionClientBuilder builder = AmazonQLDBSessionClientBuilder.standard()
    .withRegion(Regions.US_EAST_2);

Vous pouvez utiliserwithRegion cette méthode pour exécuter votre code sur QLDB dans n'importe quelle région où il est disponible. Pour obtenir la liste complète, consultez les points de terminaison et quotas Amazon QLDB dans le Références générales AWS.

Pour créer des tables dans levehicle-registration grand livre, passez àÉtape 3 : Création de tables, d'index et d'exemples de données.