Oracle NoSQL Database Migratorユーティリティは、Oracle NoSQLのダウンロード・ページからダウンロードできます。ダウンロードしてマシンに解凍すると、コマンドライン・インタフェースからrunMigratorコマンドにアクセスできます。

マイグレータを使用する前に、データ・ソースとシンクを指定する必要があります。たとえば、オンプレミスのOracle NoSQL DatabaseからJSON形式のファイルにNoSQL表を移行する場合、ソースはOracle NoSQL Databaseになり、シンクはJSONファイルになります。Oracle NoSQL Database Migratorで、「サポートされているソースとシンク」を参照して、指定したソースとシンクがサポートされていることを確認します。これは、ターゲットまたはシンクのNoSQL表のスキーマを決定して作成するための適切なフェーズでもあります。

• シンク表スキーマの識別:シンクがOracle NoSQL Databaseオンプレミスまたはクラウドの場合、シンク表のスキーマを識別し、ソース・データがターゲット・スキーマと一致することを確認する必要があります。必要に応じて、変換を使用してソース・データをシンク表にマップします。
  • デフォルト・スキーマ: NoSQL Database Migratorには、表のスキーマを事前定義する必要なく、デフォルト・スキーマを使用して表を作成するオプションがあります。これは、主にJSONファイルをOracle NoSQL Databaseにロードする場合に便利です。
    ソースがMongoDB形式のJSONファイルである場合、表のデフォルト・スキーマは次のようになります。

    CREATE TABLE IF NOT EXISTS <tablename>(ID STRING, DOCUMENT JSON,PRIMARY KEY(SHARD(ID))

    説明:

    - tablename =構成内の表属性に指定された値。

    - ID = mongoDBエクスポートしたJSONソース・ファイルの各ドキュメントからの_id値です。

    - DOCUMENT = mongoDBエクスポート・ファイルのドキュメントごとに、_idフィールドを除くコンテンツがDOCUMENT列に集計されます。

    ソースがDynamoDB形式のJSONファイルの場合、表のデフォルト・スキーマは次のとおりです。

    CREATE TABLE IF NOT EXISTS <TABLE_NAME>(DDBPartitionKey_name DDBPartitionKey_type, 
    [DDBSortKey_name DDBSortKey_type],DOCUMENT JSON,
    PRIMARY KEY(SHARD(DDBPartitionKey_name),[DDBSortKey_name]))

    説明:

    - TABLE_NAME = 構成内のシンクテーブルに指定された値

    - DDBPartitionKey_name = 構成のパーティション・キーに指定された値

    - DDBPartitionKey_type = 構成内のパーティション・キーのデータ型に指定された値

    - DDBSortKey_name = 構成のソート・キーに指定された値(ある場合)

    - DDBSortKey_type = 構成内のソート・キーのデータ型に指定された値(ある場合)

    - DOCUMENT = NoSQL JSON列に集計されたDynamo DB表アイテムのパーティションおよびソート・キーを除くすべての属性

    ソース形式がCSVファイルの場合、ターゲット表ではデフォルトのスキーマはサポートされていません。ソースCSVファイルと同じ数の列およびデータ型を含む表定義を持つスキーマ・ファイルを作成できます。スキーマ・ファイルの作成の詳細は、表スキーマの指定を参照してください。

    その他のすべてのソースでは、デフォルトのスキーマは次のようになります。

    CREATE TABLE IF NOT EXISTS <tablename> (ID LONG GENERATED ALWAYS AS IDENTITY, DOCUMENT JSON, PRIMARY KEY(ID))

    説明:

    - tablename =構成内の表属性に指定された値。

    - ID =自動生成されたLONG値。

    - DOCUMENT =ソースから提供されたJSONレコードがDOCUMENT列に集計されます。

    ノート
    
    _id値がMongoDB形式のJSONファイルに文字列として指定されていない場合、NoSQL Database Migratorはそれをデフォルト・スキーマに挿入する前に文字列に変換します。
• 表スキーマの提供: NoSQL Database Migratorを使用すると、ソースはschemaInfo属性を使用して表データのスキーマ定義を提供できます。schemaInfo属性は、すでに暗黙的スキーマが定義されていないすべてのデータ・ソースで使用できます。シンク・データ・ストアでは、次のオプションのいずれかを選択できます。
  • NoSQL Database Migratorで定義されたデフォルトのスキーマを使用します。
  • ソース指定のスキーマを使用します。
  • 独自のスキーマを定義して、ソース提供のスキーマをオーバーライドします。たとえば、ソース・スキーマから別のスキーマにデータを変換する場合は、ソース指定のスキーマをオーバーライドし、NoSQL Database Migratorツールの変換機能を使用する必要があります。
  
  
  
  
  
  The table schema file, for example, mytable_schema.ddl can include table DDL statements. The NoSQL Database Migrator tool executes this table schema file before starting the migration. The migrator tool supports no more than one DDL statement per line in the schema file. For example,

  CREATE TABLE IF NOT EXISTS(id INTEGER, name STRING, age INTEGER, PRIMARY KEY(SHARD(ID)))

• 洗面台の作成:洗面台スキーマの指定後は、管理CLIまたは洗面台構成ファイルのschemaInfo属性を使用して洗面台を作成します。シンク構成テンプレートを参照してください。
  ノート
  
  ソースがCSVファイルの場合は、ターゲット表のスキーマに対するDDLコマンドを使用してファイルを作成します。シンク構成ファイルのschemaInfo.schemaPathパラメータにファイル・パスを指定します。

NoSQL表の移行の実行時に、表の行のTTLメタデータを実際のデータとともに含めるように選択できます。NoSQL Database Migratorには、表の行TTLメタデータのエクスポートおよびインポートをサポートする構成パラメータが用意されています。また、このツールには、インポート操作中に表の行の相対的な有効期限を選択するオプションがあります。オプションで、includeTTLパラメータを使用してTTLメタデータをエクスポートまたはインポートできます。

表がエクスポートされると、有効な有効期限がある表の行についてTTLデータがエクスポートされます。行が失効しない場合、その有効期限の値は常に0であるため、エクスポートされたデータに明示的に含められません。TTL情報は、エクスポートされた各行の_metadata JSONオブジェクトに含まれています。NoSQL Database Migratorは、各行の有効期限をUNIXエポック(1970年1月1日)からのミリ秒数としてエクスポートします。例:

//Row 1
{
    "id" : 1,
    "name" : "xyz",
    "age" : 45,
    "_metadata" : {
        "expiration" : 1629709200000   //Row Expiration time in milliseconds
    }
}

//Row 2
{
    "id" : 2,
    "name" : "abc",
    "age" : 52,
    "_metadata" : {
        "expiration" : 1629709400000   //Row Expiration time in milliseconds
    }
}

//Row 3 No Metadata for below row as it will not expire
{
    "id" : 3,
    "name" : "def",
    "age" : 15
}

ユースケース2および3では、インポート操作のデフォルトの参照時間は、NoSQL Database Migratorツールが実行されているマシンのSystem.currentTimeMillis()から取得された現在の時間(ミリ秒)です。ただし、有効期限を延長し、そうでなければすぐに期限切れになる行をインポートする場合は、ttlRelativeDate構成パラメータを使用してカスタム参照時間を設定することもできます。

• ユースケース1: TTLメタデータ情報はインポート表の行に存在しません。

  外部ソースから生成されたJSONファイルをインポートする場合、または以前のバージョンの移行を使用してエクスポートする場合、インポート行にはTTL情報がありません。ただし、includeTTL構成パラメータがtrueと等しいため、移行者は表の行にTTL=0を設定します。つまり、インポート表の行は失効しません。

• ユース・ケース2:ソース表の行のTTL値は、表の行がインポートされるときの参照時間を基準にして期限切れになります。

  表の行をファイルにエクスポートし、表の行の有効期限の後にインポートしようとすると、表の行は無視され、ストアには書き込まれません。

• ユース・ケース3:表行がインポートされるとき、ソース表の行のTTL値は参照時間に対して相対的に期限切れになっていません。

  表の行をファイルにエクスポートし、表行の有効期限より前にインポートしようとすると、表行がTTL値でインポートされます。ただし、TimeToLiveクラスの整数時および日ウィンドウの制約のため、表の行の新しいTTL値はエクスポートされたTTL値と等しくできません。例:

  エクスポートされた表の行

  {
    "id" : 8,
    "name" : "xyz",
    "_metadata" : {
      "expiration" : 1629709200000 //Monday, August 23, 2021 9:00:00 AM in UTC
    }
  }

  インポート時の参照時間は1629707962582で、2021年8月23日月曜日午前8:39:22.582です。

  インポートされた表の行

  {
    "id" : 8,
    "name" : "xyz",
    "_metadata" : {
      "ttl" :  1629712800000 //Monday, August 23, 2021 10:00:00 AM UTC
    }
  }

runMigratorコマンドは、次の2通りの方法で実行できます。

1. 次に示すように、runMigratorコマンドのランタイム・オプションを使用してJSON構成ファイルを作成します。

   [~]$ ./runMigrator
   configuration file is not provided. Do you want to generate configuration? (y/n)                                                                              
    
   [n]: y
   ...
   ...

   • runMigratorユーティリティを起動すると、一連のランタイム・オプションが提供され、各オプションの選択に基づいて構成JSONファイルが作成されます。
   • ユーティリティによって構成JSONファイルが作成された後、同じ実行で移行アクティビティを続行するか、将来の移行のために構成ファイルを保存するかを選択できます。
   • 生成された構成JSONファイルを使用して移行アクティビティを続行または延期するかどうかの決定に関係なく、ファイルは将来の要件を満たすように編集またはカスタマイズできます。カスタマイズした構成JSONファイルは、後で移行するために使用できます。
2. -cまたは--configオプションを使用して、手動で作成したJSON構成ファイルをランタイム・パラメータとして渡します。-cまたは--configオプションを使用してrunMigratorコマンドを実行する前に、構成JSONファイルを手動で作成する必要があります。ソースおよびシンク構成パラメータのヘルプは、Oracle NoSQL Database Migratorリファレンスを参照してください。

   [~]$ ./runMigrator -c </path/to/the/configuration/json/file>