def METHOD_NAME(schema: CollectionSchema):
    remote_writer = RemoteBulkWriter(schema=schema,
                                     remote_path="bulk_data",
                                     local_path="/tmp/bulk_data",
                                     connect_param=RemoteBulkWriter.ConnectParam(
                                         endpoint=MINIO_ADDRESS,
                                         access_key=MINIO_ACCESS_KEY,
                                         secret_key=MINIO_SECRET_KEY,
                                         bucket_name="a-bucket",
                                     ),
                                     segment_size=50 * 1024 * 1024,
                                     )
    for i in range(10000):
        if i % 1000 == 0:
            logger.info(f"{i} rows has been append to remote writer")
        remote_writer.append_row({"id": i, "vector": [random.random() for _ in range(DIM)], "desc": f"description_{i}"})
    remote_writer.commit()
    print("test remote writer done!")
    print(remote_writer.data_path)
    return remote_writer.data_path