1. 范围读

  1. # 设置范围读的起始主键。
  2. inclusive_start_primary_key = [('uid', INF_MIN), ('gid', INF_MIN)]
  4. # 设置范围读的结束主键。
  5. exclusive_end_primary_key = [('uid', INF_MAX), ('gid', INF_MAX)]
  7. # 查询所有列。
  8. columns_to_get = []
  10. # 每次最多返回90行，如果总共有100个结果，首次查询时指定limit=90，则第一次最多返回90，最少可能返回0个结果，但是next_start_primary_key不为None。
  11. limit = 90
  13. # 设置过滤器。
  14. cond = CompositeColumnCondition(LogicalOperator.AND)
  15. cond.add_sub_condition(SingleColumnCondition("address", 'China', ComparatorType.EQUAL))
  16. cond.add_sub_condition(SingleColumnCondition("age", 50, ComparatorType.LESS_THAN))
  18. try:
  19.     # 调用get_range接口。
  20.     consumed, next_start_primary_key, row_list, next_token = client.get_range(
  21.         table_name, Direction.FORWARD,
  22.         inclusive_start_primary_key, exclusive_end_primary_key,
  23.         columns_to_get,
  24.         limit,
  25.         column_filter=cond,
  26.         max_version=1
  27.     time_range = (1557125059000, 1557129059000)  # start_time大于等于1557125059000，end_time小于1557129059000。
  28.     )
  30.     all_rows = []
  31.     all_rows.extend(row_list)
  33.     # 当next_start_primary_key不为空时，则继续读取。
  34.     while next_start_primary_key is not None:
  35.         inclusive_start_primary_key = next_start_primary_key
  36.         consumed, next_start_primary_key, row_list, next_token = client.get_range(
  37.             table_name, Direction.FORWARD,
  38.             inclusive_start_primary_key, exclusive_end_primary_key,
  39.             columns_to_get, limit,
  40.             column_filter=cond,
  41.             max_version=1
  42.         )
  43.         all_rows.extend(row_list)
  45.     # 打印主键和属性列。
  46.     for row in all_rows:
  47.         print(row.primary_key, row.attribute_columns)
  48.     print('Total rows: ', len(all_rows))
  49. # 客户端异常，一般为参数错误或者网络异常。
  50. except OTSClientError as e:
  51.     print
  52.     "get row failed, http_status:%d, error_message:%s" % (e.get_http_status(), e.get_error_message())
  53. # 服务端异常，一般为参数错误或者流控错误。
  54. except OTSServiceError as e:
  55.     print
  56.     "get row failed, http_status:%d, error_code:%s, error_message:%s, request_id:%s" % (e.get_http_status(), e.get_error_code(), e.get_error_message(), e.get_request_id())