Module: BeetleETL

Defined in:
lib/beetle_etl.rb,
lib/beetle_etl/import.rb,
lib/beetle_etl/naming.rb,
lib/beetle_etl/dsl/dsl.rb,
lib/beetle_etl/testing.rb,
lib/beetle_etl/version.rb,
lib/beetle_etl/reporter.rb,
lib/beetle_etl/steps/load.rb,
lib/beetle_etl/steps/step.rb,
lib/beetle_etl/configuration.rb,
lib/beetle_etl/steps/transform.rb,
lib/beetle_etl/steps/drop_stage.rb,
lib/beetle_etl/steps/table_diff.rb,
lib/beetle_etl/dsl/transformation.rb,
lib/beetle_etl/steps/create_stage.rb,
lib/beetle_etl/steps/map_relations.rb,
lib/beetle_etl/testing/test_wrapper.rb,
lib/beetle_etl/adapters/sequel_adapter.rb,
lib/beetle_etl/step_runner/step_runner.rb,
lib/beetle_etl/dsl/transformation_loader.rb,
lib/beetle_etl/step_runner/async_step_runner.rb,
lib/beetle_etl/step_runner/dependency_resolver.rb

Defined Under Namespace

Modules: Naming, Testing Classes: AsyncStepRunner, Configuration, CreateStage, DSL, DependencyResolver, DropStage, Import, Load, MapRelations, Reporter, SequelAdapter, Step, StepRunner, TableDiff, Transform, Transformation, TransformationLoader

Constant Summary collapse

VERSION = 
"2.0.5"
InvalidConfigurationError = 
Class.new(StandardError)
ColumnDefinitionNotFoundError = 
Class.new(StandardError)
NoColumnsDefinedError = 
Class.new(StandardError)
UnsatisfiableDependenciesError = 
Class.new(StandardError)

Class Method Summary collapse

Class Method Details

.import(config = Configuration.new) {|config| ... } ⇒ Object

Yields:

  • (config) 


33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/beetle_etl.rb', line 33

def import(config = Configuration.new)
  yield config if block_given?

  begin
    report = Import.new(config).run
    Reporter.new(config, report).log_summary
    report
  ensure
    config.disconnect_database
  end
end