Schritt 1: Erstellen Sie die CSV Quelldatei und eine Zieltabelle für den Datenupload mit DSBulk

Für dieses Tutorial verwenden wir eine Datei mit kommagetrennten Werten (CSV) mit dem Namen keyspaces_sample_table.csv als Quelldatei für die Datenmigration. Die mitgelieferte Beispieldatei enthält einige Datenzeilen für eine Tabelle mit dem Namen. book_awards

1. Erstellen Sie die Quelldatei. Sie können eine der folgenden Optionen wählen:

   • Laden Sie die CSV Beispieldatei (keyspaces_sample_table.csv) herunter, die in der folgenden Archivdatei samplemigration.zip enthalten ist. Entpacken Sie das Archiv und notieren Sie sich den Pfad zukeyspaces_sample_table.csv.

   • Um eine CSV Datei mit Ihren eigenen Daten zu füllen, die in einer Apache Cassandra-Datenbank gespeichert sind, können Sie die CSV Quelldatei dsbulk unload wie im folgenden Beispiel gezeigt auffüllen.

     dsbulk unload -k mykeyspace -t mytable -f ./my_application.conf > keyspaces_sample_table.csv

     Stellen Sie sicher, dass die von Ihnen erstellte CSV Datei die folgenden Anforderungen erfüllt:

     • Die erste Zeile enthält die Spaltennamen.

     • Die Spaltennamen in der CSV Quelldatei stimmen mit den Spaltennamen in der Zieltabelle überein.

     • Die Daten sind durch ein Komma getrennt.

     • Alle Datenwerte sind gültige Amazon Keyspaces-Datentypen. Siehe Datentypen.

2. Erstellen Sie den Zielschlüsselraum und die Zieltabelle in Amazon Keyspaces.

   1. Connect zu Amazon Keyspaces hercqlsh, indem Sie den Service-Endpunkt, den Benutzernamen und das Passwort im folgenden Beispiel durch Ihre eigenen Werte ersetzen.

      cqlsh cassandra.us-east-2.amazonaws.com 9142 -u "111122223333" -p "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY" --ssl

   2. Erstellen Sie einen neuen Schlüsselraum mit dem Namen, catalog wie im folgenden Beispiel gezeigt.

      CREATE KEYSPACE catalog WITH REPLICATION = {'class': 'SingleRegionStrategy'};

   3. Wenn der neue Schlüsselraum den Status verfügbar hat, verwenden Sie den folgenden Code, um die Zieltabelle zu erstellen. book_awards Weitere Informationen zur asynchronen Ressourcenerstellung und zur Überprüfung, ob eine Ressource verfügbar ist, finden Sie unter. Überprüfen Sie den Status der Schlüsselraumerstellung in Amazon Keyspaces

      CREATE TABLE catalog.book_awards (
         year int,
         award text,
         rank int, 
         category text,
         book_title text,
         author text, 
         publisher text,
         PRIMARY KEY ((year, award), category, rank)
         );

   Wenn Apache Cassandra Ihre ursprüngliche Datenquelle ist, besteht eine einfache Möglichkeit, die Amazon Keyspaces-Zieltabelle mit passenden Headern zu erstellen, darin, die CREATE TABLE Anweisung aus der Quelltabelle zu generieren, wie in der folgenden Anweisung gezeigt.

   cqlsh localhost 9042  -u "username" -p "password" --execute "DESCRIBE TABLE mykeyspace.mytable;"

   Erstellen Sie dann die Zieltabelle in Amazon Keyspaces mit den Spaltennamen und Datentypen, die der Beschreibung aus der Cassandra-Quelltabelle entsprechen.