Redisデータソースの設定
Redisはオープンソースのインメモリデータ構造ストアで、データベース、キャッシュ、メッセージミドルウェアとして広く使われています。
このドキュメントでは、Redisのデータ同期機能の対応状況について説明します。
対応バージョン
redis 3.0+
使用制限
現在、次の構成方法にのみ対応しています：
- AEプリセット倉庫の空間テーブルからRedisへの書き込み（オフライン書き込み）に対応
注：
- Redisデータソースの読み取り（オフライン読み取り）には現在対応していません
対応するフィールドタイプ
| フィールドタイプ | オフライン書き込み（Writer） |
|---|---|
| tinyint | 対応 |
| smallint | 対応 |
| integer | 対応 |
| bigint | 対応 |
| varchar | 対応 |
| boolean | 対応 |
| double | 対応 |
| date | 対応 |
| timestamp | 対応 |
array(tinyint) array(smallint) array(integer) array(bigint) array(varchar) array(boolean) array(double) | 対応 |
| array(その他) | 未対応 |
| row | 対応 |
| map | 対応 |
| varchar | 対応 |
Redisデータソースの作成
データ開発プラットフォーム - バッチ統合 モジュールで、Redisデータソースを追加を選択できます
データソース設定パラメータ情報
データソースに必要な設定情報を入力し、接続性テストが完了すると、Redisデータソースを作成できます。
パラメータ名の前に * が付いているものは必須パラメータ、* が付いていないものは任意パラメータです。
| フィールド名 | 説明 |
|---|---|
| 基本情報 | |
| *データソース名 | データ開発プラットフォームのスペース内で一意である必要があります。英字、数字、アンダースコアの組み合わせで、数字やアンダースコアで始めることはできません |
| 備考 | 任意 |
| データソース設定 | |
| 環境を区別しない / 独立環境構成 | いずれかを選択：「環境を区別しない」は本番環境と開発環境で1セットの構成を共用することを表し、「独立環境構成」は2つの環境をそれぞれ独立して設定することを表します |
| *デプロイモード |
|
| *サーバーアドレス/IP | Redisデータベースがあるサーバーのアドレス クラスタ構成の場合、複数のノード情報を入力するには「追加」をクリックしてください |
| *ポート | Redisへのアクセスに使用するポート |
| ユーザー名 | データベースへのアクセス権限を持つユーザー名 |
| *パスワード | ユーザー名に対応するパスワード情報 |
| 高度な構成 | データベースへの接続に必要なその他の高度なパラメータ。自由に入力できます |
オフライン同期タスクの作成
上記の手順でRedisデータソースを作成し、接続性テストに成功したら、実際のシナリオに応じてRedisオフライン書き込みのタスクを設定できます。
データの流向としてのRedis
データの流向としてRedisを選択し、以下の関連パラメータを設定します：
| フィールド名 | 説明 |
|---|---|
| *ソースタイプ | データの流向のターゲットタイプとしてRedisを選択 |
| *データソース名 | データソース管理画面で登録済みのRedisデータソースを、ドロップダウンから選択できます。 対応するデータソースをまだ作成していない場合は、データソース管理 ボタンをクリックして、Redisデータソースを作成できます。 |
| *データベースの選択 | データベースを識別するRedis db slotのインデックス *このパラメータは 非クラスタモード のソースにのみあります |
*書き込みデータタイプ | Redis Valueのデータタイプ string、set、hash、list の4種類から選択できます。 |
| *書き込みモード |
|
| バッチ件数 | バッチ件数：1バッチで送信するデータ量。デフォルトは1000件 |
| 有効期限 | Redisにデータを書き込む際に、keyに有効期限を設定できます。単位は日/時間/分/秒から選択でき、スイッチはデフォルトでオフです |
パラメータ名の前に * が付いているものは必須パラメータ、* が付いていないものは任意パラメータです。
フィールド照合
データソースとターゲット側の設定が完了したら、フィールドを解析し、Redis Keyの保存方法を設定します。
インデックスキー（Key）の連結ルール
Redisはキーバリューストアであり、キー（Key）の設計はクエリの効率と保守性に直接影響します。
ユーザーが使いやすいように、キーの連結と保存について次の機能を提供しています
- 指定フィールド の書き込みに対応（i.e テーブル全体ではない書き込み）
- キーの プレフィックス設定 & サフィックス設定 に対応
- 変数を挿入（空間パラメータ）に対応
- 特殊文字を挿入に対応
- キー全体がルールチェックに合格する必要があります
インデックスキー（Key）の設定
| キー関連の設定 | ||
|---|---|---|
| フィールド名 | 説明 | 必須かどうか |
| キーのプレフィックス/サフィックス | プレフィックスとサフィックスをユーザーが自由に定義できます redisのkeyが汚染されないよう、使用できるのは[0-9A-Za-z-_]のみです。 入力例：student:tuition:${bd} | いいえ |
| フィールド値を挿入 | 左側のソーステーブルでチェック済みのフィールドのみ選択できます | いいえ |
| 変数を挿入 | プリセットの空間パラメータとカスタムの空間パラメータに対応しています | いいえ |
| 特殊文字を挿入 | 例：\u0001 | いいえ |
| データプレビュー | デフォルトで 3 件表示されます | |
基本情報の設定
最後に、統合プランの基本情報を設定する必要があります。プラン名、責任者、統合の同期速度、備考などが含まれます。
設定が完了したら、「保存」 ボタンをクリックして統合プランの作成を完了できます。
注：プラン名は保存後に変更できません
詳細ページの表示：
オフライン同期プランのタスクフローへのマウント
マウントされたタスクフロー
1.マウント手順を開始する
- 統合プランの詳細ページで、右上の「ジョブフローにマウントする」ボタンをクリックします
2.タスクフローを選択する
-
ドロップダウンメニューから対象のタスクフローを選択します
-
タスクフローを新規作成する場合：
- ドロップダウンメニューの下にある「タスクフローを新規作成」ショートカットボタンをクリックします
- または「開発」モジュールで作成します
-
ヒント：対象のタスクフローが表示されない場合は、右側の↻更新ボタンをクリックしてください
3.同期ノードを作成する
- タスクフロー内で「オフライン同期プラン」タイプのノードを新規作成します
- このノードは現在の統合プランに関連付けられ、ノードの実行時に対応する統合プランの実行がトリガーされます
4.マウントを完了する
- 「ノードを作成し、マウントします」をクリックして設定を完了します
- マウントに成功したら、「タスクフローに進む」をクリックしてマウント結果をすぐに確認できます
注：タスクフローへのマウントで作成されたタスクノードは 未リリース状態 です。タスクフローを確認し、そのノードをリリースして配信を開始することをお勧めします。
タスクフローのマウント解除
オフライン同期プランのタスクフローへのマウントを解除する場合：
- タスクフローがまだリリースされていない場合は、そのプランがマウントされているタスクフローに移動し、開発モード でその「オフライン同期プラン」タスクノードを削除するだけです。
- タスクフローがすでにリリースされている場合は、開発モード でその「オフライン同期プラン」タスクノードを削除した後、タスクフローを再リリースする必要があります。これにより、本番環境 でのそのノードのマウントも同時に解除されます。