SQLBucket was built to help write, orchestrate and validate SQL ETL. It gives the possibility to set variables and introduces some control flow like if/else and for loops, to make your queries dynamic when writing them. It also implements a very simplistic integration testing framework to validate the results of your ETL pipelines in the form of SQL checks.
Lightweight, it can work as a stand alone service, or be part of your workflow manager environment (Airflow, Luigi, ..).
Installing
Install and update using pip:
pip install -U sqlbucketSQLBucket works only for Python 3.6 and 3.7, and probably 3.8 although not tested yet.
A Simple Example
To start working with SQLBucket, you need to have a ‘projects’ folder that will contain all your SQL ETL. SQLBucket, essentially works with the following folder structure as a root folder, where you can have as many projects as you want.
projects/
|-- project1/
|-- project2/
|-- project3/
...Inside a project, it must contain a folder called queries that will contains your SQL files to be ran, and a config.yaml that will let you set the order in which those queries must be processed. SQLBucket leverages on the amazing Jinja2 templating library to give you the possibility to set variables in your SQL as well as giving you pure execution flows like for loops. To see in more depth what can be done, see the documentation on how to write SQL in SQLBucket.
In practice, this is how a project folder would look.
projects/
|-- my_super_project/
|-- config.yaml
|-- queries/
|-- my_super_insert_query.sql
|-- some_other_query.sql
|-- integrity/
|-- test1.sql
|-- test2.sqlThe integrity folder gives you the possibility to write some checks in SQL, that will ran at the end of your ETL to validate your data. Check documentation on integrity for a more detailed explanation on testing the integrity of your ETL.
This is how you would launch a project:
from sqlbucket import SQLBucket
connections = {
'db_test': 'postgresql://user:password@host:5439/database'
}
bucket = SQLBucket(connections=connections)
project = bucket.load_project(
project_name='fat_etl',
connection_name='db_test',
variables={'foo': 1}
)
project.run()
project.run_integrity()This would trigger logs as below.
You can also launch a project using the sqlbucket command line interface.
Contributing
For guidance on how to make a contribution to SQLBucket, see the contributing guidelines.
Links
License: MIT
Releases: https://pypi.org/project/sqlbucket/
Issue tracker: https://github.com/socialpoint-labs/sqlbucket/issues
3 maintainers
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file sqlbucket-0.2.7.tar.gz.
File metadata
- Download URL: sqlbucket-0.2.7.tar.gz
- Upload date:
- Size: 11.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/1.13.0 pkginfo/1.5.0.1 requests/2.9.1 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.35.0 CPython/3.5.3
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
645950c8547f8bbc7bb3a796dcec28c51cc3ce9c29086727775bc67cbc8fde13
|
|
| MD5 |
d56a554e79b95548a0b71dd1fb7f381f
|
|
| BLAKE2b-256 |
dbceaee5f0765f881c92c64f0d947ecb9bbb4e224598f706079a878b6ad1f92e
|
File details
Details for the file sqlbucket-0.2.7-py3-none-any.whl.
File metadata
- Download URL: sqlbucket-0.2.7-py3-none-any.whl
- Upload date:
- Size: 12.4 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/1.13.0 pkginfo/1.5.0.1 requests/2.9.1 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.35.0 CPython/3.5.3
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
8808ce4228484257f57ce4f3b18adbf401f31d48ab48d4671402a2b94e193f10
|
|
| MD5 |
b78e0d37ed6df494300d3b40ccc7c096
|
|
| BLAKE2b-256 |
fb2648797a1365e5c73f5aa6a43c8af121fd3e30555973e2d550f084b2da6098
|
