TiCDC CSV プロトコル

クラウドstorageサービスをダウンストリーム シンクとして使用する場合、DML イベントを CSV 形式でクラウドstorageサービスに送信できます。

CSVを使用する

CSV プロトコルを使用する場合の構成例を次に示します。

cdc cli changefeed create --server=http://127.0.0.1:8300 --changefeed-id="csv-test" --sink-uri="s3://bucket/prefix" --config changefeed.toml

changefeed.tomlファイル内の構成は次のとおりです。

[sink]
protocol = "csv"
terminator = "\n"

[sink.csv]
delimiter = ',' # Before v7.6.0, you can only set the delimiter to a single character. Starting from v7.6.0, you can set it to 1-3 characters. For example, `$^` or `|@|`.
quote = '"'
null = '\N'
include-commit-ts = true
output-old-value = false

トランザクション制約

• 単一の CSV ファイルでは、行のcommit-tsが後続の行の 1 と等しいかそれより小さくなります。
• 単一テーブルの同じトランザクションが同じ CSV ファイルに保存されます。
• 同じトランザクションの複数のテーブルを異なる CSV ファイルに保存できます。

データstorageパス構造

データのstorageパス構造の詳細については、 ストレージパス構造参照してください。

データ形式の定義

CSV ファイルでは、各列は次のように定義されます。

• カラム1: 操作タイプ インジケータ。 I 、 U 、 Dが含まれます。 IはINSERT 、 UはUPDATE 、 D DELETE意味します。
• カラム2: テーブル名。
• カラム3: スキーマ名。
• カラム4: ソース トランザクションのcommit-tsこの列はオプションです。
• カラム5: 列is-updateは、値output-old-valueが true の場合にのみ存在し、行データの変更が UPDATE イベント (列の値が true) によるものか、INSERT/DELETE イベント (値が false) によるものかを識別するために使用されます。
• 6カラムから最後の列まで: データが変更された 1 つ以上の列。

表hr.employeeが次のように定義されていると仮定します。

CREATE TABLE `employee` (
  `Id` int NOT NULL,
  `LastName` varchar(20) DEFAULT NULL,
  `FirstName` varchar(30) DEFAULT NULL,
  `HireDate` date DEFAULT NULL,
  `OfficeLocation` varchar(20) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

include-commit-ts = trueおよびoutput-old-value = falseの場合、このテーブルの DML イベントは次のように CSV 形式で保存されます。

"I","employee","hr",433305438660591626,101,"Smith","Bob","2014-06-04","New York"
"U","employee","hr",433305438660591627,101,"Smith","Bob","2015-10-08","Los Angeles"
"D","employee","hr",433305438660591629,101,"Smith","Bob","2017-03-13","Dallas"
"I","employee","hr",433305438660591630,102,"Alex","Alice","2017-03-14","Shanghai"
"U","employee","hr",433305438660591630,102,"Alex","Alice","2018-06-15","Beijing"

include-commit-ts = trueおよびoutput-old-value = trueの場合、このテーブルの DML イベントは次のように CSV 形式で保存されます。

"I","employee","hr",433305438660591626,false,101,"Smith","Bob","2014-06-04","New York"
"D","employee","hr",433305438660591627,true,101,"Smith","Bob","2015-10-08","Shanghai"
"I","employee","hr",433305438660591627,true,101,"Smith","Bob","2015-10-08","Los Angeles"
"D","employee","hr",433305438660591629,false,101,"Smith","Bob","2017-03-13","Dallas"
"I","employee","hr",433305438660591630,false,102,"Alex","Alice","2017-03-14","Shanghai"
"D","employee","hr",433305438660591630,true,102,"Alex","Alice","2017-03-14","Beijing"
"I","employee","hr",433305438660591630,true,102,"Alex","Alice","2018-06-15","Beijing"

データ型マッピング