great_expectations.datasource.batch_kwargs_generator.query_batch_kwargs_generator

Module Contents

Classes

QueryBatchKwargsGenerator(name=’default’, datasource=None, query_store_backend=None, queries=None)

Produce query-style batch_kwargs from sql files stored on disk

great_expectations.datasource.batch_kwargs_generator.query_batch_kwargs_generator.logger
great_expectations.datasource.batch_kwargs_generator.query_batch_kwargs_generator.sqlalchemy
class great_expectations.datasource.batch_kwargs_generator.query_batch_kwargs_generator.QueryBatchKwargsGenerator(name='default', datasource=None, query_store_backend=None, queries=None)

Bases: great_expectations.datasource.batch_kwargs_generator.batch_kwargs_generator.BatchKwargsGenerator

Produce query-style batch_kwargs from sql files stored on disk

recognized_batch_parameters
_get_raw_query(self, data_asset_name)
_get_iterator(self, data_asset_name, query_parameters=None)
add_query(self, generator_asset=None, query=None, data_asset_name=None)
get_available_data_asset_names(self)

Return the list of asset names known by this batch kwargs generator.

Returns

A list of available names

_build_batch_kwargs(self, batch_parameters)

Build batch kwargs from a partition id.

get_available_partition_ids(self, generator_asset=None, data_asset_name=None)

Applies the current _partitioner to the batches available on data_asset_name and returns a list of valid partition_id strings that can be used to identify batches of data.

Parameters

data_asset_name – the data asset whose partitions should be returned.

Returns

A list of partition_id strings