def scan_tbl()

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)