Stream Load
1. Stream Load は、CSV 形式のファイルの最初の数行に含まれる列名を識別したり、データ読み取り中に最初の数行をスキップしたりすることをサポートしていますか？
Stream Load は、CSV 形式のファイルの最初の数行に含まれる列名を識別することをサポートしていません 。Stream Load は、最初の数行を他の行と同様に通常のデータとして扱います。
バージョン 2.5 以前では、Stream Load はデータ読み取り中に CSV ファイルの最初の数行をスキップすることをサポートしていません。ロードしたい CSV ファイルの最初の数行に列名が含まれている場合は、以下のいずれかの操作を行ってください。
- データをエクスポートするために使用するツールの設定を変更します。その後、最初の数行に列名が含まれていない CSV ファイルとしてデータを再エクスポートします。
sed -i '1d' filenameなどのコマンドを使用して、CSV ファイルの最初の数行を削除します。- ロードコマンドまたはステートメントで
-H "where: <column_name> != '<column_name>'"を使用して、CSV ファイルの最初の数行をフィルタリングします。<column_name>は、最初の数行に含まれる列名のいずれかです。StarRocks は最初にソースデータを変換し、その後フィルタリングを行います。そのため、最初の数行の列名が対応するデータ型に変換されない場合、それらにはNULL値が返されます。つまり、StarRocks の宛先テーブルにはNOT NULLに設定された列を含めることはできません。 - ロードコマンドまたはステートメントで
-H "max_filter_ratio:0.01"を追加して、最大エラー許容率を 1% 以下に設定し、最初の数行のデータ変換失敗を無視できるようにします。この場合、ErrorURLがエラーロウを示すために返されても、Stream Load ジョブは成功することができます。max_filter_ratioを大き な値に設定しないでください。大きな値に設定すると、重要なデータ品質の問題が見逃される可能性があります。
バージョン 3.0 以降、Stream Load は skip_header パラメータをサポートしており、CSV ファイルの最初の数行をスキップするかどうかを指定できます。詳細については、CSV parameters を参照してください。
2. パーティション列にロードするデータが標準の DATE または INT 型ではありません。例えば、データが 202106.00 のような形式です。Stream Load を使用してデータをロードする場合、どのようにデータを変換すればよいですか？
StarRocks は、ロード時にデータを変換することをサポートしています。詳細については、Transform data at loading を参照してください。
例えば、TEST という名前の CSV 形式のファイルをロードしたいとします。このファイルは NO、DATE、VERSION、PRICE の 4 列で構成されており、そのうち DATE 列のデータは 202106.00 のような非標準形式です。StarRocks で DATE をパーティション列として使用したい場合、まず StarRocks テーブルを作成する必要があります。例えば、NO、VERSION、PRICE、DATE の 4 列で構成されるものです。その後、StarRocks テーブルの DATE 列のデータ型を DATE、DATETIME、または INT に指定する必要があります。最後に、Stream Load ジョブを作成する際に、ロードコマンドまたはステートメントで以下の設定を指定して、ソース DATE 列のデータ型を宛先列のデータ型に変換します。
-H "columns: NO,DATE_1, VERSION, PRICE, DATE=LEFT(DATE_1,6)"
上記の例では、DATE_1 は宛先 DATE 列にマッピン グされる一時的な名前の列と見なすことができ、宛先 DATE 列にロードされる最終結果は left() 関数によって計算されます。まずソース列の一時的な名前をリストし、その後に関数を使用してデータを変換する必要があります。サポートされている関数はスカラー関数であり、非集計関数やウィンドウ関数を含みます。
3. Stream Load ジョブが "body exceed max size: 10737418240, limit: 10737418240" エラーを報告した場合、どうすればよいですか？
ソースデータファイルのサイズが 10 GB を超えており、これは Stream Load がサポートする最大ファイルサイズです。以下のいずれかの操作を行ってください。
seq -w 0 nを使用して、ソースデータファイルを小さなファイルに分割します。curl -XPOST http://be_host:http_port/api/update_config?streaming_load_max_mb=<file_size>を使用して、BE configuration itemstreaming_load_max_mbの値を調整し、最大ファイルサイズを増やします。
