📣
TiDB Cloud Premium はパブリックプレビュー中です。エンタープライズワークロード向けの無制限のスケーリング、即時の弾力性、高度なセキュリティを提供します。このページは自動翻訳されたものです。原文はこちらからご覧ください。
AI
開発者向け
ベストプラクティス
API

TiDBとAmazon AppFlowを統合する

Amazon AppFlow Software as a Service (SaaS) アプリケーションを AWS サービスに接続し、データを安全に転送するために使用するフルマネージド API 統合サービスです。 Amazon AppFlow を使用すると、TiDB との間で、Salesforce、Amazon S3、LinkedIn、GitHub などのさまざまなタイプのデータプロバイダーにデータをインポートおよびエクスポートできます。詳細については、AWS ドキュメントのサポートされている送信元および送信先アプリケーション参照してください。

このドキュメントでは、TiDBをAmazon AppFlowと統合する方法について説明し、 TiDB Cloud Starterインスタンスの統合を例として取り上げます。

TiDB Cloud Starterインスタンスをお持ちでない場合は、 TiDB Cloudクイックスタート手順に従って作成できます。インスタンスは無料で、約30秒で作成できます。

前提条件

ステップ1. TiDBコネクタを登録する

コードを複製する

TiDB と Amazon AppFlow の統合例のコードリポジトリクローンを作成します。

git clone https://github.com/pingcap-inc/tidb-appflow-integration

Lambda関数を構築してアップロードする

  1. パッケージを作成する：

    cd tidb-appflow-integration
mvn clean package

  2. （オプション）AWSアクセスキーIDとシークレットアクセスキーを設定していない場合は、設定してください。

    aws configure

  3. JARパッケージをLambda関数としてアップロードしてください。

    sam deploy --guided

    注記：

    • --guidedオプションでは、プロンプトが表示され、デプロイの手順を案内します。入力内容は構成ファイルに保存され、デフォルトではsamconfig.tomlというファイルになります。
    • stack_nameデプロイする AWS Lambda の名前を指定します。
    • このガイドでは、TiDB Cloud Starterのクラウド プロバイダーとして AWS を使用しています。ソースまたは宛先として Amazon S3 を使用するには、AWS Lambda のregionを Amazon S3 と同じに設定する必要があります。
    • 既にsam deploy --guidedを実行したことがある場合は、代わりにsam deployを実行するだけで、SAM CLI は設定ファイルsamconfig.tomlを使用して操作を簡素化します。

    以下のような出力が表示された場合、このLambda関数は正常にデプロイされています。

    Successfully created/updated stack - <stack_name> in <region>

  4. AWS Lambdaコンソールにアクセスすると、先ほどアップロードしたLambda関数が表示されます。ウィンドウの右上隅で正しいリージョンを選択する必要があることに注意してください。

    lambda dashboard

Lambdaを使用してコネクタを登録します

  1. AWS マネジメントコンソールコンソールで、 Amazon AppFlow > コネクタクリックし、 [新しいコネクタの登録] をクリックします。

    register connector

  2. 「新しいコネクタを登録」ダイアログで、アップロードしたLambda関数を選択し、コネクタ名を使用してコネクタラベルを指定します。

    register connector dialog

  3. 「登録」をクリックします。すると、TiDBコネクタが正常に登録されます。

ステップ2. フローを作成する

Amazon AppFlow > フローし、 [フローの作成] をクリックします。

create flow

フロー名を設定します

フロー名を入力し、 「次へ」をクリックします。

name flow

ソーステーブルと宛先テーブルを設定します。

ソースの詳細と宛先の詳細を選択してください。TiDBコネクタはどちらにも使用できます。

  1. ソース名を選択してください。このドキュメントでは、例としてSalesforceをソースとして使用します。

    salesforce source

    Salesforceに登録すると、Salesforceはプラットフォームにサンプルデータを追加します。以下の手順では、アカウントオブジェクトをサンプルソースオブジェクトとして使用します。

    salesforce data

  2. 「接続」をクリックしてください。

    1. 「Salesforceに接続」ダイアログで、この接続の名前を指定し、 「続行」をクリックします。

      connect to salesforce

    2. 「許可」をクリックして、AWSがSalesforceデータを読み取ることを許可することを確認してください。

      allow salesforce

    注記：

    会社がすでに Salesforce の Professional Edition を使用している場合、REST API はデフォルトでは有効になっていません。 REST API を使用するには、新しい Developer Edition の登録が必要になる場合があります。詳細については、 Salesforceフォーラムトピックを参照してください。

  3. 「接続先の詳細」エリアで、接続先として「TiDB-Connector」を選択します。「接続」ボタンが表示されます。

    tidb dest

  4. 「接続」をクリックする前に、Salesforce Accountオブジェクト用に TiDB にsf_accountテーブルを作成する必要があります。このテーブルスキーマはAmazon AppFlow のチュートリアルにあるサンプルデータとは異なることに注意してください。

    CREATE TABLE `sf_account` (
    `id` varchar(255) NOT NULL,
    `name` varchar(150) NOT NULL DEFAULT '',
    `type` varchar(150) NOT NULL DEFAULT '',
    `billing_state` varchar(255) NOT NULL DEFAULT '',
    `rating` varchar(255) NOT NULL DEFAULT '',
    `industry` varchar(255) NOT NULL DEFAULT '',
    PRIMARY KEY (`id`)
);

  5. sf_accountテーブルが作成されたら、 [接続]をクリックします。接続ダイアログが表示されます。

  6. TiDBコネクタへの接続ダイアログで、 TiDB Cloud Starterインスタンスの接続プロパティを入力します。TiDB Cloud Starterの場合、 TLSオプションをYesに設定する必要があります。これにより、TiDBコネクタがTLS接続を使用できるようになります。次に、 [接続]をクリックします。

    tidb connection message

  7. これで、接続時に指定したデータベース内のすべてのテーブルを取得できます。ドロップダウンリストからsf_accountテーブルを選択してください。

    database

    次のスクリーンショットは、Salesforce Accountオブジェクトから TiDB のsf_accountテーブルにデータを転送するための設定を示しています。

    complete flow

  8. エラー処理領域で、 「現在のフロー実行を停止する」を選択します。フローのトリガー領域で、 「オンデマンドで実行」トリガータイプを選択します。これは、フローを手動で実行する必要があることを意味します。次に、 「次へ」をクリックします。

    complete step1

マッピングルールを設定する

Salesforce のAccountオブジェクトのフィールドを TiDB のsf_accountテーブルにマッピングし、 [次へ]をクリックします。

  • sf_accountテーブルは TiDB に新しく作成されましたが、空です。

    test> SELECT * FROM sf_account;
+----+------+------+---------------+--------+----------+
| id | name | type | billing_state | rating | industry |
+----+------+------+---------------+--------+----------+
+----+------+------+---------------+--------+----------+

  • マッピングルールを設定するには、左側でソースフィールド名を選択し、右側で宛先フィールド名を選択します。次に、 「フィールドのマッピング」をクリックすると、ルールが設定されます。

    add mapping rule

  • このドキュメントでは、以下のマッピングルール（ソースフィールド名→宛先フィールド名）が必要です。

    • アカウントID -> id
    • アカウント名 -> 名前
    • アカウントタイプ -> タイプ
    • 請求先州/都道府県 -> billing_state
    • アカウント評価 -> 評価
    • 産業 -> 産業

    mapping a rule

    show all mapping rules

（オプション）フィルターを設定する

データフィールドにフィルターを追加したい場合は、ここで設定できます。そうでない場合は、この手順をスキップして「次へ」をクリックしてください。

filters

フローを確認して作成する

作成するフローの情報を確認してください。問題がなければ、 「フローを作成」をクリックします。

review

ステップ3. フローを実行する

新しく作成したフローのページで、右上隅にある「フローを実行」をクリックします。

run flow

以下のスクリーンショットは、フローが正常に実行された例を示しています。

run success

sf_accountテーブルをクエリすると、Salesforce Accountオブジェクトのレコードがそこに書き込まれていることが確認できます。

test> SELECT * FROM sf_account;
+--------------------+-------------------------------------+--------------------+---------------+--------+----------------+
| id                 | name                                | type               | billing_state | rating | industry       |
+--------------------+-------------------------------------+--------------------+---------------+--------+----------------+
| 001Do000003EDTlIAO | Sample Account for Entitlements     | null               | null          | null   | null           |
| 001Do000003EDTZIA4 | Edge Communications                 | Customer - Direct  | TX            | Hot    | Electronics    |
| 001Do000003EDTaIAO | Burlington Textiles Corp of America | Customer - Direct  | NC            | Warm   | Apparel        |
| 001Do000003EDTbIAO | Pyramid Construction Inc.           | Customer - Channel | null          | null   | Construction   |
| 001Do000003EDTcIAO | Dickenson plc                       | Customer - Channel | KS            | null   | Consulting     |
| 001Do000003EDTdIAO | Grand Hotels & Resorts Ltd          | Customer - Direct  | IL            | Warm   | Hospitality    |
| 001Do000003EDTeIAO | United Oil & Gas Corp.              | Customer - Direct  | NY            | Hot    | Energy         |
| 001Do000003EDTfIAO | Express Logistics and Transport     | Customer - Channel | OR            | Cold   | Transportation |
| 001Do000003EDTgIAO | University of Arizona               | Customer - Direct  | AZ            | Warm   | Education      |
| 001Do000003EDThIAO | United Oil & Gas, UK                | Customer - Direct  | UK            | null   | Energy         |
| 001Do000003EDTiIAO | United Oil & Gas, Singapore         | Customer - Direct  | Singapore     | null   | Energy         |
| 001Do000003EDTjIAO | GenePoint                           | Customer - Channel | CA            | Cold   | Biotechnology  |
| 001Do000003EDTkIAO | sForce                              | null               | CA            | null   | null           |
+--------------------+-------------------------------------+--------------------+---------------+--------+----------------+

注目すべきこと

お困りですか？

このページは役に立ちましたか？