RemoteBulkWriter
RemoteBulkWriter インスタンスは、生データを Zilliz Cloud が理解できる形式で AWS-S3 互換バケットに書き込みます。
class pymilvus.RemoteBulkWriter
Constructor
スキーマ、remote_path、connect_param などの一連のパラメータを使用して RemoteBulkWriter オブジェクトを構築します。
RemoteBulkWriter オブジェクトは、生データを Zilliz Cloud が理解できる形式に書き換えて AWS-S3 互換バケットに格納することを目的としています。
from pymilvus import CollectionSchema
from pymilvus.bulk_writer import RemoteBulkWriter, BulkFileType
writer = RemoteBulkWriter(
schema=CollectionSchema(),
remote_path="string",
connect_param=RemoteBulkWriter.ConnectParam()
chunk_size=512*1024*1024,
file_type=BulkFileType.PARQUET
)
PARAMETERS:
-
スキーマ (CollectionSchema) -
[REQUIRED]
書き換えられたデータのインポート先となる対象コレクションのスキーマです。
-
remote_path (str) -
[REQUIRED]
書き換えられたデータを格納するディレクトリへのパスです。
-
connect_param (ConnectParam) -
リモートバケットへの接続に使用するパラメータです。
-
chunk_size (int) -
ファイルセグメントの最大サイズです。
生データの書き換え時に、Zilliz Cloud は生データをセグメントに分割します。
デフォルト値は 536,870,912 バイトで、512 MB です。
NoteBulkWriter はどのようにデータをセグメント化しますか?
BulkWriter によるデータのセグメント化の方法は、対象のファイルタイプによって異なります。
生成されたファイルが指定されたセグメントサイズを超える場合、BulkWriter は複数のファイルを作成し、それぞれがセグメントサイズを超えないように連番で名前を付けます。
-
file_type (BulkFileType) -
出力ファイルのタイプです。
デフォルト値は BulkFileType.PARQUET です。
指定可能なオプションは BulkFileType.JSON、BulkFileType.PARQUET、BulkFileType.CSV です。
-
config (dict)
CSV ファイルを処理するためのオプション設定を指定する辞書です。このパラメータは、file_type が BulkFileType.CSV に設定されている場合にのみ使用できます。設定例:
pythonconfig={"sep": "\t","nullkey": "NULL"}-
sep (string)
CSV ファイルの区切り文字です。値は長さ 1 の文字列である必要があり、デフォルトは
","です。次の文字列は使用できません:"\0"、"\n"、"\r"、"""。 -
nullkey (string)
null 値を表す特別な文字列です。デフォルト値は空文字列
""です。
-
RETURN TYPE:
RemoteBulkWriter
RETURNS:
RemoteBulkWriter オブジェクト。
EXCEPTIONS:
-
SchemaNotReadyException
指定されたスキーマが無効な場合に、この例外が発生します。
Properties
-
data_path (pathlib.PosixPath) -
出力ディレクトリへのパスです。
-
batch_files (str) -
生成されたファイル名のリストです。
Classes
以下は RemoteBulkWriter クラスに含まれるクラスです。
- ConnectParam
Methods
以下は RemoteBulkWriter クラスのメソッドです: