in parquet_flask/aws/aws_ddb.py [0:0]
def scan_tbl(self, conditions_dict):
LOGGER.info('scanning items from DDB using they key')
current_tbl = self._ddb_resource.Table(self.__props.tbl_name)
item_result = current_tbl.scan(
Limit=1,
ScanFilter=conditions_dict,
Select='ALL_ATTRIBUTES')
all_results = item_result['Items']
while 'LastEvaluatedKey' in item_result and item_result['LastEvaluatedKey'] is not None: # pagination
item_result = current_tbl.scan(
Limit=100,
ScanFilter=conditions_dict,
ExclusiveStartKey=item_result['LastEvaluatedKey'],
Select='ALL_ATTRIBUTES')
all_results.extend(item_result['Items'])
return self._replace_decimals(all_results)