Batch Analytics

PySpark-based analytics pipeline for ClickHouse data: Extract → Transform → Stage → Analytics. Designed to run as the main application inside a Spark driver container (invoked by analytics_runners via SparkApplication CRD).

Bundle contents

Only the files required for the batch analytics job runner:

analytics/
├── pyproject.toml
├── requirements.txt          # core + scipy + boto3 + clickhouse-connect (single-file install)
├── requirements-batch.txt  # includes requirements.txt
├── README.md
└── src/
    └── batch_analytics/
        ├── __init__.py
        ├── __main__.py        # python -m batch_analytics
        ├── job_runner.py      # Entry point
        ├── config.py
        ├── extract.py
        ├── transform.py
        ├── log.py
        ├── README.md
        └── analytics/
            ├── __init__.py
            ├── linear_regression.py
            ├── correlation.py
            ├── pca_clustering.py
            └── t_test.py

Install

pip install batch-analytics — core (numpy only)
pip install batch-analytics[spark] — PySpark ETL + job runner + SciPy (t-test / ANOVA)
pip install batch-analytics[autogluon] — AutoGluon + I/O (Gluon image; no PySpark)
pip install batch-analytics[full] — PySpark + AutoGluon + I/O

pip install -e ".[spark]"   # dev

Run

# Via module
python -m batch_analytics

# Via CLI (after pip install -e .)
batch-analytics

# Full pipeline
batch-analytics

# Analytics only (from staged ClickHouse table)
batch-analytics --from-stage --modules lr corr pca ttest

Configuration

See src/batch_analytics/README.md for environment variables and usage.

Docker image

For Spark on Kubernetes, build an image that includes this package and exposes job_runner.py at the path used by mainApplicationFile (e.g. local:///opt/analytics/job_runner.py).

Metadata

Release files for batch-analytics 0.3.222

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for batch-analytics 0.3.222
File	Size	Uploaded
batch_analytics-0.3.222.tar.gz	29.9 kB	Apr 7, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for batch-analytics 0.3.222
File	Interpreter	ABI	Platform	Reset
batch_analytics-0.3.222-py3-none-any.whl 38.6 kB Apr 7, 2026	Python 3	none	any	Details

Total release size: 68.5 kB

Release files / batch_analytics-0.3.222.tar.gz

Download URL	batch_analytics-0.3.222.tar.gz
Size	29.9 kB
Tags	Source
SHA-256 checksum How to use checksums	`eeebcc02959096af1961c377b5af01059c2bf30206eaca3beab28b206f9b2d5e`
BLAKE2b-256 checksum How to use checksums	`fafc5fed6dd516ee606109dd63ed6d8b87a9e273a38f5e309097ea35541de922`
Upload date	Apr 7, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.12.3`

Release files / batch_analytics-0.3.222-py3-none-any.whl

Download URL	batch_analytics-0.3.222-py3-none-any.whl
Size	38.6 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`76ea95b798d2dc0eb9f7ced81decfe147295475b2c8a1dd3ce230216b2823cd4`
BLAKE2b-256 checksum How to use checksums	`71c3dbc9bddb112e1fc88132c322de981e6dde0997c372a0ea4bffc931c5ef83`
Upload date	Apr 7, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.12.3`