数据是从BigQuery中提取的,我们确定该间隔存在。
使用的代码:
client = aerospike.client(config).connect()
query = client.query('test', 'demo')
query.select('pickup', 'passenger_count')
# query.where(p.between('passenger_count',1,3))
def print_result(args):
key, metadata, record = args
print(record)
query.foreach(print_result)