ステップ 1: を使用してデータアップロード用のソースCSVファイルとターゲットテーブルを作成する DSBulk - Amazon Keyspaces (Apache Cassandra 向け)

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

ステップ 1: を使用してデータアップロード用のソースCSVファイルとターゲットテーブルを作成する DSBulk

このチュートリアルでは、データ移行のソースファイルkeyspaces_sample_table.csvとして という名前のカンマ区切り値 (CSV) ファイルを使用します。提供されたサンプルファイルには、book_awards という名前のテーブルに関する数行のデータが含まれています。

  1. ソースファイルを作成します。次のオプションのいずれかを選択します。

    • 次のアーカイブCSVファイル samplemigration.zip に含まれているサンプルファイル (keyspaces_sample_table.csv) をダウンロードします。 samples/samplemigration.zipアーカイブを解凍し、keyspaces_sample_table.csv へのパスをメモしておきます。

    • Apache Cassandra データベースに保存されている独自のデータをCSVファイルに入力するには、次の例dsbulk unloadに示すように、 を使用してソースCSVファイルを入力します。

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

      作成するCSVファイルが次の要件を満たしていることを確認します。

      • 最初の行に列名が含まれています。

      • ソースCSVファイルの列名は、ターゲットテーブルの列名と一致します。

      • データがカンマで区切られてます。

      • すべてのデータ値が有効な Amazon Keyspaces データ型です。「データ型」を参照してください。

  2. Amazon Keyspaces でターゲットのキースペースとテーブルを作成します。

    1. cqlsh を使用して Amazon Keyspaces に接続し、次の例のサービスエンドポイント、ユーザー名、およびパスワードをそれぞれ独自の値に置き換えます。

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

    2. 次の例に示すように、catalog という名前の新しいキースペースを作成します。

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

    3. 新しいキースペースが利用可能な状態になったら、次のコードを使用してターゲットテーブル book_awards を作成します。非同期的なリソース作成と、リソースが利用可能かどうかを確認する方法については、「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)
   );

    Apache Cassandra が元のデータソースである場合、ヘッダーが一致している Amazon Keyspaces ターゲットテーブルを作成する簡単な方法は、次のステートメントに示すように、ソーステーブルから CREATE TABLE ステートメントを生成する方法です。

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

    次に、Amazon Keyspaces で、列名とデータ型が Cassandra ソーステーブルの説明と一致しているターゲットテーブルを作成します。