append_row()

This operation appends records to the writer.

Request syntax

append_row(
    row: dict
)

PARAMETERS:

row (dict) -

A dictionary representing an entity to be appended.

The keys and their values in the dictionary should match the schema referenced in the current LocalBulkWriter.

Examples

from pymilvus import (
    CollectionSchema, 
    FieldSchema, 
    LocalBulkWriter, 
    DataType, 
    BulkFileType
)

# Set up a schema
schema = CollectionSchema(fields=[
    FieldSchema(name="id", dtype=DataType.INT64, is_primary=True),
    FieldSchema(name="vector", dtype=DataType.FLOAT_VECTOR, dim=5),
    ]
)

# Set up a local bulk writer
writer = LocalBulkWriter(
    schema=schema,
    local_path="/tmp/output",
)

# Append a row to the writer
writer.append_row(
    {"id": 0, "vector": [0.1, 0.4, -0.8, -0.2, 0.4]}
)

Related methods

commit()