1. listQuery = {
    2.     'is_use': True,
    3.     'value': '选择'
    4. }
    2.     def search(self,
    3.                listQuery = {},
    4.                limit = 30, next_token_str = ''):
    5.         recover_next_token = next_token_str.encode('utf-8')
    6.         must_queries = []
    7.         for column_name, column_dict in listQuery.items():
    8.             # 遍历所有的查询条件
    9.             if isinstance(column_dict, (dict)):
    10.                 if column_dict['is_use']:
    11.                     # 如果用户选中了此筛选条件
    12.                     if column_dict['type'] == 'TermQuery':
    13.                         must_queries.append(TermQuery(column_name, column_dict['value']))
    14.                     if column_dict['type'] == 'WildcardQuery':
    15.                         must_queries.append(WildcardQuery(column_name,'*'+column_dict['value']+'*'))
    16.                     if column_dict['type'] == 'RangeQuery':
    17.                         must_queries.append(RangeQuery(field_name=column_name,
    18.                                                        range_from=column_dict['range_from'],
    19.                                                        range_to=column_dict['range_to']
    20.                                                        ))
    23.         bool_query = BoolQuery(
    24.             must_queries=must_queries
    25.         )
    27.         if next_token_str != '':
    28.             # 第2此进行搜索查询
    29.             SearchQueryInstance = SearchQuery(bool_query,
    30.                             next_token=recover_next_token,
    31.                             limit=limit,
    32.                             get_total_count=True)
    33.         else:
    34.             # 首次进行搜索查询
    35.             SearchQueryInstance = SearchQuery(bool_query,
    36.                             next_token=recover_next_token,
    37.                             # sort=Sort(sorters=[FieldSort('create_time',SortOrder.DESC)]),
    38.                             limit=limit,
    39.                             get_total_count=True)
    41.         search_response = self.__OTSClientInstance__.search(
    42.             self._table_name_, self._init_index_,
    43.             SearchQueryInstance,
    44.             ColumnsToGet(return_type=ColumnReturnType.ALL)
    45.         )
    46.         rows = search_response.rows
    47.         next_token = search_response.next_token
    48.         total_count = search_response.total_count
    49.         return_rows = []
    51.         for s_row in rows:
    52.             s_row = table_store_row_to_dict(s_row)
    54.             return_rows.append(s_row)
    56.         # 解码函数
    57.         next_token_str = next_token.decode('utf-8')
    59.         return return_rows, next_token_str, total_count