Redis 出力コンポーネントを構成することにより、外部データベースから Redis にデータを書き込んだり、ビッグデータプラットフォームと統合されたストレージシステムから Redis にデータを転送およびプッシュして、データ統合と再処理を行うことができます。このトピックでは、Redis 出力コンポーネントの構成プロセスについて説明します。
前提条件
操作を開始する前に、次のタスクが完了していることを確認してください。
Redis データソースが作成されていること。詳細については、「Redis データソースの作成」をご参照ください。
Redis 出力プロパティを構成するには、アカウントがデータソースに対するリードスルー権限を持っている必要があります。この権限がない場合は、データソースにリクエストする必要があります。詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
手順
Dataphin ホームページの上部メニューバーで、[開発] > [data Integration] を選択します。
統合ページの上部メニューバーで、プロジェクト を選択します(開発-本番モードでは環境を選択する必要があります)。
左側のナビゲーションウィンドウで、[バッチパイプライン] をクリックします。[バッチパイプライン] リストで、開発が必要な オフラインパイプライン をクリックして、構成ページを開きます。
ページの右上隅にある [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側のナビゲーションウィンドウで、[出力] を選択します。右側の出力コンポーネントのリストで [redis] コンポーネントを見つけて、キャンバスにドラッグします。
ターゲットのアップストリームコンポーネントの
アイコンをクリックしてドラッグし、Redis 出力コンポーネントに接続します。Redis 出力コンポーネントカードの
アイコンをクリックして、[redis 出力構成] ダイアログボックスを開きます。
[redis 出力構成] ダイアログボックスで、以下の表に概説されているようにパラメーターを設定します。
パラメーター
説明
基本設定
[ステップ名]
これは Redis 出力コンポーネントの名前です。Dataphin は自動的にステップ名を生成しますが、ビジネスシナリオに基づいて変更できます。命名規則は次のとおりです。
日本語、英字、アンダースコア (_)、および数字のみ使用できます。
64 文字を超えることはできません。
[データソース]
データソースドロップダウンリストには、書き込みスルー権限を持つデータソースと持たないデータソースを含む、すべての Redis タイプのデータソースが表示されます。
アイコンをクリックして、現在のデータソース名をコピーします。書き込みスルー権限のないデータソースの場合、データソースの後に [リクエスト] をクリックして書き込みスルー権限をリクエストできます。詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
Redis タイプのデータソースをまだ持っていない場合は、[データソースの作成] をクリックして作成します。詳細については、「Redis データソースの作成」をご参照ください。
[DB]
クラスタモードでは、DB は不要です。スタンドアロンモードでは、DB を 0 ~ 255 の範囲で指定する必要があります。デフォルトは 0 です。
[キー列]
キーとして使用する列を選択してください。
[キーセパレーター]
キーを書き込むためのセパレーター。キー列が複数ある場合に有効です。例:
\u0001。複数文字のセパレーターをサポートします。[書き込みデータ型]
Redis に書き込む値の型を選択してください。
[書き込み][モード]
書き込みモードを選択してください。
[JSON 形式で書き込む]
[書き込みデータ型] が文字列として構成されている場合にのみサポートされます。「はい」の場合、値列の列名と値は、構成されたマッピング関係に従って JSON 形式でターゲット Redis に書き込まれます。「いいえ」の場合、値は値セパレーターを使用して書き込まれます。
[値セパレーター]
値を書き込むためのセパレーター。例:
\u0001。複数文字のセパレーターをサポートします。詳細設定
[キャッシュ有効期限]
キャッシュ有効期限は、[有効期間]、[有効期限 - 定数]、または [有効期限 - フィールドから選択] をサポートします。
有効期間:データの有効期間の秒数を入力する必要があります。
有効期限 - 定数:有効期限を選択する必要があります。その後、データは無効になります。
有効期限 - フィールドから選択:有効期限列のフィールドを選択する必要があります。その後、データは無効になります。
[書き込みタイムアウト]
Redis への書き込みのタイムアウト。デフォルトは 300 秒です。
[キープレフィックス]
キーのプレフィックスとして文字列を構成できます。日本語、英字、数字、アンダースコア (_) をサポートします。
フィールドマッピング
[入力フィールド]
アップストリーム入力フィールドが表示されます。
[出力フィールド]
出力フィールドが表示されます。出力フィールドの手動追加をサポートします。
[一括追加] をクリックすると、以下に示すように、JSON 形式と TEXT 形式での一括構成がサポートされます。
JSON 形式
"column":[ { "index":5, "name":"test1", "type":"STRING" }, { "index":2, "name":"partition", "type":"STRING" } ]TEXT 形式
paper_no,String phone_no,String vip_no,String行区切り文字:行区切り文字は各フィールドの情報を区切るために使用されます。デフォルトは改行(\n)で、
\n ; .をサポートします。列区切り文字:列区切り文字はフィールド名とフィールドタイプを区切るために使用されます。デフォルトはカンマで、(,) をサポートします。フィールドタイプは省略できます。デフォルトは (,) です。
追加されたフィールドに対して次の操作を実行することもできます。
[アクション] 列の
アイコンをクリックして、既存のフィールドを編集します。[アクション] 列の
アイコンをクリックして、既存のフィールドを削除します。
[マッピング]
アップストリーム入力とターゲットテーブルのフィールドに基づいて、フィールドマッピングを手動で選択できます。クイックマッピングには、[同じ名前のマッピング] と [同じ行のマッピング] が含まれます。
[確認] をクリックして、Redis 出力コンポーネントの構成を完了します。.