AnalyticDB for MySQL 2.0 出力コンポーネントは、AnalyticDB for MySQL 2.0 データソースにデータを書き込みます。他のデータソースから AnalyticDB for MySQL 2.0 にデータを同期する場合、ソースデータソース情報を構成した後、ターゲットデータソースを構成する必要があります。このトピックでは、AnalyticDB for MySQL 2.0 出力コンポーネントを構成する方法について説明します。
手順
Dataphin ホームページの上部ナビゲーションバーで、[開発] > [Data Integration] を選択します。
統合ページの上部ナビゲーションバーで、プロジェクト を選択します。開発-本番モードでは、環境 を選択する必要があります。
左側のナビゲーションバーで、[バッチパイプライン] をクリックします。[バッチパイプライン] リストで、開発するオフラインパイプラインをクリックして、構成ページを開きます。
ページの右上隅にある [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側のナビゲーションバーで、[出力] を選択します。右側の出力コンポーネントリストで、[AnalyticDB For MySQL 2.0] コンポーネントを見つけて、キャンバスにドラッグします。
ターゲット入力、変換、またはフローコンポーネントの
アイコンをクリックしてドラッグし、現在の AnalyticDB for MySQL 2.0 出力コンポーネントに接続します。AnalyticDB for MySQL 2.0 出力コンポーネントカードの
アイコンをクリックして、AnalyticDB for MySQL 2.0 [出力構成] ダイアログボックスを開きます。
[AnalyticDB For MySQL 2.0 出力構成] ダイアログボックスで、パラメーターを構成します。
パラメーター
説明
[基本設定]
[ステップ名]
AnalyticDB for MySQL 2.0 出力コンポーネントの名前。Dataphin は自動的にステップ名を生成しますが、ビジネスシナリオに基づいて変更できます。名前は次の要件を満たしている必要があります:
中国語の文字、英字、アンダースコア(_)、数字のみを含めることができます。
長さは 64 文字を超えることはできません。
[データソース]
データソースのドロップダウンリストには、ライトスルー権限を持つデータソースと持たないデータソースを含め、すべての AnalyticDB for MySQL 2.0 データソースが表示されます。
アイコンをクリックして、現在のデータソース名をコピーします。ライトスルー権限のないデータソースの場合、データソースの横にある [リクエスト] をクリックして、ライトスルー権限をリクエストできます。詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
AnalyticDB for MySQL 2.0 データソースがない場合は、[データソースの作成] をクリックして作成します。詳細については、「AnalyticDB for MySQL 2.0 データソースの作成」をご参照ください。
タイムゾーン
時間形式のデータを処理するために使用されるタイムゾーン。デフォルトは、選択したデータソースで構成されたタイムゾーンで、変更できません。
説明V5.1.2 より前に作成されたタスクの場合、[データソースのデフォルト構成] または [チャネル構成のタイムゾーン] を選択できます。デフォルトは、[チャネル構成のタイムゾーン] です。
[データソースのデフォルト構成]: 選択したデータソースのデフォルトのタイムゾーン。
[チャネル構成のタイムゾーン]: 現在の統合タスクの [プロパティ] > [チャネル構成] で構成されたタイムゾーン。
[テーブル]
出力データのターゲットテーブルを選択します。キーワードを入力してテーブルを検索するか、正確なテーブル名を入力して [完全一致] をクリックします。テーブルを選択すると、システムは自動的にテーブルの状態をチェックします。
アイコンをクリックして、現在選択されているテーブルの名前をコピーします。[モード]
データ出力モードを選択します。[モード] には以下が含まれます。
[挿入モード]: 挿入モードは、少量のデータ (1,000 万 レコード未満) の書き込みをサポートします。[準備ステートメント] と [完了ステートメント] を構成する必要があります。
[準備ステートメント]: インポート前に実行する SQL スクリプト。
[完了ステートメント]: インポート後に実行する SQL スクリプト。
[ロードモード]: ロードモードは、大量のデータ (1,000 万 レコード以上) の書き込みをサポートします。ロードポリシー、ロードパラメーター、および Alibaba Cloud アカウントを構成する必要があります。
[ロードポリシー]：ターゲットテーブルにデータを書き込むためのポリシーを選択します。
[データの上書き] は、ターゲットテーブルの既存データが現在のソーステーブルに基づいて上書きされることを意味します。
[データの追加] は、既存データを変更せずに、ターゲットテーブルの既存データにデータが追加されることを意味します。
[ロードパラメーター]: MaxCompute 転送に使用される接続。JSON 形式で入力します。例:
{"accessid":"XXX","accessKey":"XXX","odpsServer":"XXX","tunnelServer":"XXX","accountType":"aliyun","project":"transfer_project"}[Alibaba Cloud アカウント]: ロードモードで必須です。Alibaba Cloud アカウントは、ロードデータの承認に使用されます。コンテンツは ALIYUN$****_data@aliyun.com として入力されます。
[バッチ書き込みデータ量]（オプション）
一度に書き込むデータのサイズ。[バッチ書き込み数] を設定することもできます。システムは、これらの 2 つの構成のいずれかが制限に達すると、データを書き込みます。デフォルトは 32M です。
[フィールドマッピング]
[入力フィールド]
アップストリーム入力に基づいて入力フィールドを表示します。
[出力フィールド]
出力フィールドを表示します。次の操作を実行できます:
フィールド管理: [フィールド管理] をクリックして、出力フィールドを選択します。
アイコンをクリックして、[選択された入力フィールド] を [選択されていない入力フィールド] に移動します。
アイコンをクリックして、[選択されていない入力フィールド] を [選択された入力フィールド] に移動します。
一括追加: [一括追加] をクリックして、JSON、TEXT、または DDL 形式で構成します。
JSON 形式で構成します。例:
// 例: [{ "name": "user_id", "type": "String" }, { "name": "user_name", "type": "String" }]説明name はインポートされたフィールドの名前を示し、type はインポート後のフィールドタイプを示します。たとえば、
"name":"user_id","type":"String"は、user_id という名前のフィールドをインポートし、そのタイプを String に設定することを意味します。TEXT 形式で構成します。例:
// 例: user_id,String user_name,String行区切り文字は、各フィールドの情報を区切るために使用されます。デフォルトは改行 (\n) です。サポートされている区切り文字には、改行 (\n)、セミコロン (;)、ピリオド (.) が含まれます。
列区切り文字は、フィールド名とフィールドタイプを区切るために使用されます。デフォルトはカンマ (,) です。
DDL 形式で構成します。例:
CREATE TABLE tablename ( id INT PRIMARY KEY, name VARCHAR(50), age INT );
新しい出力フィールドを作成する: [+出力フィールドの作成] をクリックし、プロンプトに従って [列] に入力し、[タイプ] を選択します。現在の行の構成が完了したら、
アイコンをクリックして保存します。
[マッピング]
アップストリーム入力とターゲットテーブルのフィールドに基づいて、フィールドマッピングを手動で選択できます。マッピング には、[同じ行のマッピング] と [同じ名前のマッピング] が含まれます。
同じ名前のマッピング: 同じ名前のフィールドをマッピングします。
同じ行のマッピング: ソーステーブルとターゲットテーブルのフィールド名が異なるが、対応する行のデータをマッピングする必要がある場合、同じ行のフィールドをマッピングします。
[OK] をクリックして、[AnalyticDB For MySQL 2.0] 出力コンポーネントのプロパティ構成を完了します。