exporters package

Subpackages

• exporters.export_formatter package
  • Submodules
  • exporters.export_formatter.base_export_formatter module
  • exporters.export_formatter.csv_export_formatter module
  • exporters.export_formatter.json_export_formatter module
  • Module contents
• exporters.export_managers package
  • Subpackages
    • exporters.export_managers.settings package
      • Submodules
      • exporters.export_managers.settings.default_settings module
      • Module contents
  • Submodules
  • exporters.export_managers.base_exporter module
  • exporters.export_managers.bypass module
  • exporters.export_managers.unified_exporter module
  • Module contents
• exporters.filters package
  • Submodules
  • exporters.filters.base_filter module
  • exporters.filters.key_value_filter module
  • exporters.filters.key_value_regex_filter module
  • exporters.filters.no_filter module
  • exporters.filters.pythonexp_filter module
  • Module contents
• exporters.groupers package
  • Submodules
  • exporters.groupers.base_grouper module
  • exporters.groupers.file_key_grouper module
  • exporters.groupers.no_grouper module
  • Module contents
• exporters.integration_tests package
  • Submodules
  • exporters.integration_tests.configs module
  • exporters.integration_tests.run_tests module
  • Module contents
• exporters.logger package
  • Submodules
  • exporters.logger.base_logger module
  • Module contents
• exporters.notifications package
  • Submodules
  • exporters.notifications.base_notifier module
  • exporters.notifications.notifiers_list module
  • exporters.notifications.receiver_groups module
  • exporters.notifications.s3_mail_notifier module
  • exporters.notifications.webhook_notifier module
  • Module contents
• exporters.persistence package
  • Submodules
  • exporters.persistence.alchemy_persistence module
  • exporters.persistence.base_persistence module
  • exporters.persistence.base_sqlalchemy_persistence module
  • exporters.persistence.persistence_config_dispatcher module
  • exporters.persistence.pickle_persistence module
  • Module contents
• exporters.pipeline package
  • Submodules
  • exporters.pipeline.base_pipeline_item module
  • Module contents
• exporters.readers package
  • Submodules
  • exporters.readers.base_reader module
  • exporters.readers.hubstorage_reader module
  • exporters.readers.kafka_random_reader module
  • exporters.readers.kafka_scanner_reader module
  • exporters.readers.random_reader module
  • exporters.readers.s3_reader module
  • Module contents
• exporters.records package
  • Submodules
  • exporters.records.base_record module
  • Module contents
• exporters.transform package
  • Submodules
  • exporters.transform.base_transform module
  • exporters.transform.jq_transform module
  • exporters.transform.no_transform module
  • exporters.transform.pythonexp_transform module
  • Module contents
• exporters.writers package
  • Submodules
  • exporters.writers.base_writer module
  • exporters.writers.console_writer module
  • exporters.writers.fs_writer module
  • exporters.writers.ftp_writer module
  • exporters.writers.s3_writer module
  • exporters.writers.sftp_writer module
  • exporters.contrib.writers.odo module
  • Module contents

Submodules

exporters.exceptions module

exception exporters.exceptions.ConfigCheckError(message="Configuration provided isn't valid.", errors={})

Bases: exporters.exceptions.ConfigurationError

exception exporters.exceptions.ConfigurationError

Bases: exceptions.ValueError

Configuration provided isn’t valid.

exception exporters.exceptions.InvalidDateRangeError

Bases: exceptions.ValueError

Empty or impossible date range

exception exporters.exceptions.InvalidExpression

Bases: exceptions.Exception

exception exporters.exceptions.UnsupportedCompressionFormat

Bases: exceptions.ValueError

Unsupported compression format.

exception exporters.exceptions.WriterNotSupportingGroupedBatch

Bases: exceptions.Exception

exporters.exporter_options module

exporters.module_loader module

class exporters.module_loader.ModuleLoader

Bases: object

load_class(class_path)

load_decompressor(options, metadata, **kwargs)

load_deserializer(options, metadata, **kwargs)

load_filter(options, metadata, **kwargs)

load_formatter(options, metadata, **kwargs)

load_grouper(options, metadata, **kwargs)

load_notifier(options, metadata, **kwargs)

load_persistence(options, metadata, **kwargs)

load_reader(options, metadata, **kwargs)

load_stats_manager(options, metadata, **kwargs)

load_transform(options, metadata, **kwargs)

load_write_buffer(options, metadata, **kwargs)

load_writer(options, metadata, **kwargs)

exporters.python_interpreter module

class exporters.python_interpreter.Interpreter

Bases: object

allowed_objects = (<type 'str'>, <type 'unicode'>, <type 'int'>, <type 'float'>, <type 'long'>, <type 'complex'>, <type 'list'>, <type 'dict'>, <type 'set'>, <type 'tuple'>, <type 'NoneType'>, <type 'bool'>)

ast_allowed_nodes = ('keyword', 'expr', 'name', 'load', 'call', 'store', 'str', 'unicode', 'num', 'list', 'dict', 'set', 'tuple', 'unaryop', 'usub', 'binop', 'add', 'sub', 'div', 'mult', 'mod', 'pow', 'floordiv', 'compare', 'eq', 'noteq', 'gt', 'lt', 'gte', 'lte', 'bitand', 'bitor', 'bitxor', 'invert', 'lshift', 'rshift', 'boolop', 'and', 'or', 'not', 'in', 'notin', 'is', 'isnot', 'ifexp', 'subscript', 'index', 'slice', 'extslice', 'listcomp', 'setcomp', 'dictcomp', 'generatorexp', 'comprehension', 'attribute')

check(expression)

eval(expression, context=None, check=True)

exporters.python_interpreter.create_context(**kwargs)

Module contents