Skip to main content

ETL flow framework based on Yaml configs in Python

Project description

logo

ETL flow framework based on Yaml configs in Python

Supported Python Versions License Code style: black

A light framework for creating data streams. Setting up streams through configuration in the Yaml file. There is a schedule, task pools, concurrency limitation. Works quickly, does not require a lot of resources. Runs on Windows and Linux. Flow run in parallel via threading library. Internally SQLite Database.

At the moment there are connectors to sources

  • CSV file
  • SQLite database
  • Yandex Metrika Management API
  • Yandex Metrika Stats API
  • Yandex Metrika Logs API
  • Yandex Direct API
  • Yandex Direct Report API

Storages

  • Save to csv file
  • Clickhouse

Documentation

Requirements

  • python >=3.9
  • virtual environment

Settings

It is highly recommended to install in a virtual environment.

Flowmaster needs a home, '{HOME}/FlowMaster' is the default,
but you can lay foundation somewhere else if you prefer
(optional)

For Windows

setx FLOWMASTER_HOME "{YOUR_PATH}"

For Linux

export FLOWMASTER_HOME={YOUR_PATH}

Installing

pip install flowmaster==0.6.0

Run

flowmaster run

args

flowmaster run --help

CHANGELOG

Support

Telegram support chat

Author

Pavel Maksimov

My contacts Telegram, Facebook

Удачи тебе, друг! Поставь звездочку ;)

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

FlowMaster-0.6.0.tar.gz (46.7 kB view details)

Uploaded Source

File details

Details for the file FlowMaster-0.6.0.tar.gz.

File metadata

  • Download URL: FlowMaster-0.6.0.tar.gz
  • Upload date:
  • Size: 46.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.4.1 importlib_metadata/4.3.0 pkginfo/1.4.2 requests/2.23.0 requests-toolbelt/0.8.0 tqdm/4.45.0 CPython/3.6.3

File hashes

Hashes for FlowMaster-0.6.0.tar.gz
Algorithm Hash digest
SHA256 81111a8f5991ccbae042b28b4bf7dfc73337291530beef1de089eda3296bcc65
MD5 f88ace96fc877450687a7b8d422f0a7c
BLAKE2b-256 afccadc4706d8a3d229bd4dfb145f4ec3fb4ab6c982e64bb44c64327733e1f72

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page