A Python gRPC client library for Vald.
Using pip,
pip install vald-client-pythonTo use v1 APIs,
importgrpcfromvald.v1.valdimportinsert_pb2_grpcfromvald.v1.valdimportsearch_pb2_grpcfromvald.v1.valdimportupdate_pb2_grpcfromvald.v1.valdimportremove_pb2_grpcfromvald.v1.valdimportflush_pb2_grpcfromvald.v1.payloadimportpayload_pb2## create a channel by passing "{host}:{port}"channel=grpc.insecure_channel("gateway.vald.vdaas.org:80")
## create stubs for calling RPCsistub=insert_pb2_grpc.InsertStub(channel)
sstub=search_pb2_grpc.SearchStub(channel)
ustub=update_pb2_grpc.UpdateStub(channel)
rstub=remove_pb2_grpc.RemoveStub(channel)
fstub=flush_pb2_grpc.FlushStub(channel)
## call RPCs: Insertvec=payload_pb2.Object.Vector(id='vector_id_1', vector=[0.1, 0.2, 0.3])
icfg=payload_pb2.Insert.Config(skip_strict_exist_check=True)
istub.Insert(payload_pb2.Insert.Request(vector=vec, config=icfg))
## call RPCs: Search### num: number of results### timeout: 3 secondsscfg=payload_pb2.Search.Config(num=10, radius=-1.0, epsilon=0.01, timeout=3000000000)
res=sstub.Search(payload_pb2.Search.Request(vector=[0.1, 0.2, 0.3], config=scfg))
## call RPCs: Updateuvec=payload_pb2.Object.Vector(id='vector_id_1', vector=[0.1, 0.2, 0.3])
ucfg=payload_pb2.Update.Config(skip_strict_exist_check=True)
ustub.Update(payload_pb2.Update.Request(vector=uvec, config=ucfg))
## call RPCs: Removercfg=payload_pb2.Remove.Config(skip_strict_exist_check=True)
rid=payload_pb2.Object.ID(id='vector_id_1')
rstub.Remove(payload_pb2.Remove.Request(id=rid, config=rcfg))
## call RPCs: Flushfstub.Flush(payload_pb2.Flush.Request())
## close channelchannel.close()