nebula-python==2.6.0
nebula == 2.6.2
from nebula2.mclient import MetaCache, HostAddr
from nebula2.sclient.GraphStorageClient import GraphStorageClient
import logging
logging.basicConfig(level=logging.DEBUG, format='[%(asctime)s] %(levelname)-8s [%(filename)s:%(lineno)d]:%(message)s')
logger = logging.getLogger(__name__)
logger.debug('debug msg')
# the metad server's address
meta_cache = MetaCache([('10.1.1.248', 49171)], 100)
storage_addrs = [HostAddr(host='10.1.1.248', port=49170)]
graph_storage_client = GraphStorageClient(meta_cache, storage_addrs)
resp = graph_storage_client.scan_vertex(
space_name='test',
tag_name='person')
print(resp._req)
print(resp.has_next())
result = resp.next()
print(result)
ScanVertexRequest(
space_id=7,
part_id=0,
return_columns=VertexProp(
tag=8,
props=[b'_vid', b'name', b'age']),
limit=1000,
start_time=0,
end_time=9223372036854775807,
only_latest_version=False,
enable_read_from_follower=True)
True
[2022-08-16 16:34:45,095] DEBUG [ScanResult.py:104]:Graph storage client num: 1
程序一直卡在result = resp.next()
