This release is a pre-release and may not be stable for production use.
| PyPI | GitHub | Info | Stats |
|---|---|---|---|
 |
 |
 |
 |
 |
 |
 |
 |
What is Meerschaum?
Meerschaum is an ETL framework for time-series data. You define pipes — named data streams — and Meerschaum keeps them in sync: it fetches only the new or changed rows, deduplicates and upserts them, manages the schema, and handles scheduling, serving, and storage.
Write a few lines of fetch logic; Meerschaum handles the rest of the pipeline. No more copy/pasting ETL scripts, hand-rolling incremental windows, or babysitting cron jobs. Drop it into an existing stack or stand up a full database-and-dashboard stack in minutes.
import meerschaum as mrsm
pipe = mrsm.Pipe('plugin:noaa', 'weather', 'atl', instance='sql:local')
pipe.sync() ### Pulls only what's new since the last sync.
Features
- ⚡️ Incremental by default — the sync engine fetches only new or changed rows and concurrently updates many streams at once. Duplicate rows are ignored; rows with existing keys are updated.
- 📊 Built for data scientists and analysts — integrate with Pandas, Grafana, and friends; persist DataFrames and always get the latest data. Skip pandas overhead and read rows as plain dicts with
Pipe.get_docs(). - 🗄️ Production-ready, batteries included — one-click deploy a TimescaleDB + Grafana stack, serve data org-wide via
FastAPI(uvicorn/gunicorn), and secure API instances with scoped auth tokens. Supports PostGIS geometry (incl. ESRI CRS) for geospatial pipelines. - 💼 Jobs and scheduling — run any command as a background job with
-d. Built-in scheduler handles cron and interval schedules — nocrontaborsystemdsetup. Execute locally, viasystemd, or remotely on an API instance with--executor-keys. - 🔌 Easily expandable — ingest any source with a simple plugin: just return a DataFrame. Add any function as a command, define parent/child pipe relationships for composable SQL pipelines, or embed Meerschaum via its Python API.
- ✨ Tailored for your experience — a rich CLI that's surprisingly enjoyable, a web dashboard for the graphically inclined, and connectors for SQL, API, Valkey, and custom backends.
- 🧳 Portable from the start —
$MRSM_ROOT_DIRemulates multiple installations and groups instances. The base wheel has no required Python dependencies (the native core is inside it; anything optional installs into a virtual environment), and it'suv-compatible:uv tool install meerschaum.
Want to learn more?
Find a wealth of information at meerschaum.io, or read up on Meerschaum in the wild:
- Interview featured in Console 100 - The Open Source Newsletter
- A Data Scientist's Guide to Fetching COVID-19 Data in 2022 (Towards Data Science)
- Time-Series ETL with Meerschaum (Towards Data Science)
- How I automatically extract my M1 Finance transactions
Installation
For a more thorough setup guide, visit the Getting Started page at meerschaum.io.
TL;DR
pip install meerschaum # or `uv tool install meerschaum[api]`
mrsm stack up -d
mrsm bootstrap pipes
Meerschaum 5 is a Rust core with a Python SDK. pip install meerschaum installs it; for a standalone mrsm binary run cargo install meerschaum --locked (Rust 1.95 or newer). Upgrading from 4.x? Read the migration guide.
Usage
Visit meerschaum.io for setup, usage, and troubleshooting information. You can find technical documentation at docs.meerschaum.io.
CLI
### Install the NOAA weather plugin.
mrsm install plugin noaa
### Register a new pipe to the built-in SQLite DB.
### You can instead run `bootstrap pipe` for a wizard.
### Enter 'KATL' for Atlanta when prompted.
mrsm register pipe -c plugin:noaa -m weather -l atl -i sql:local
### Pull data and create the table "plugin_noaa_weather_atl".
mrsm sync pipes -l atl -i sql:local
Python API
import meerschaum as mrsm
pipe = mrsm.Pipe(
'foo', 'bar',
instance = 'sql:local', ### Built-in SQLite DB.
columns = {'datetime': 'dt', 'id': 'id'},
)
### Sync a DataFrame (or list of dicts) — creates the table on first run.
pipe.sync([{'dt': '2024-07-01', 'id': 1, 'val': 10}])
### Duplicates are ignored; rows with existing keys are updated.
pipe.sync([{'dt': '2024-07-01', 'id': 1, 'val': 100}])
assert pipe.get_rowcount() == 1
### Read back as a DataFrame, filtered by time range and params.
df = pipe.get_data(begin='2024-01-01', end='2025-01-01', params={'id': [1]})
### Or skip pandas and read plain dicts.
docs = pipe.get_docs(params={'id': [1]})
### [{'dt': datetime(2024, 7, 1), 'id': 1, 'val': 100}]
For composable in-database SQL pipelines (reference inheritance and {{ Pipe(...) }} table resolution), see the SQL pipes guide.
Plugins
Ingest any source by returning rows from a fetch function — Meerschaum handles the rest:
# ~/.config/meerschaum/plugins/example.py
__version__ = '1.0.0'
required = ['requests']
def register(pipe, **kw):
return {'columns': {'datetime': 'dt', 'id': 'id'}}
def fetch(pipe, begin=None, end=None, **kw):
import requests
rows = requests.get('https://api.example.com/data').json()
return rows ### list of dicts or a Pandas DataFrame
Support Meerschaum's Development
For consulting services and to support Meerschaum's development, please considering sponsoring me on GitHub sponsors.
Additionally, you can always buy me a coffee☕!
License
Copyright 2020-2026 Bennett Meares
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
1 maintainer
Metadata
1 maintainer
Release files for meerschaum 5.0.0rc12
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | Provenance | |
|---|---|---|---|---|
| meerschaum-5.0.0rc12.tar.gz | 4.1 MB | Without provenance | Details |
Built distributions (wheels)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| meerschaum-5.0.0rc12-cp314-cp314t-manylinux_2_28_x86_64.whl | CPython 3.14 | CPython 3.14 free-threading | Linux glibc 2.28+ x86-64 | Details |
| meerschaum-5.0.0rc12-cp311-abi3-musllinux_1_2_x86_64.whl | CPython 3.11 | abi3 | Linux musl 1.2+ x86-64 | Details |
| meerschaum-5.0.0rc12-cp311-abi3-manylinux_2_28_x86_64.whl | CPython 3.11 | abi3 | Linux glibc 2.28+ x86-64 | Details |
Total release size: 110.2 MB
Release files / meerschaum-5.0.0rc12.tar.gz
| Download URL | meerschaum-5.0.0rc12.tar.gz |
|---|---|
| Size | 4.1 MB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
798526fe3af1f2763b7701027428b03cfc9a6022d5c03fe8969f813346cf7c0f
|
|
BLAKE2b-256 checksum How to use checksums |
6092c820579a9cc026d8f571abc16b468d576fe931b05fb5ed2891a8de17c1e5
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.14.8
|
Release files / meerschaum-5.0.0rc12-cp314-cp314t-manylinux_2_28_x86_64.whl
| Download URL | meerschaum-5.0.0rc12-cp314-cp314t-manylinux_2_28_x86_64.whl |
|---|---|
| Size | 35.2 MB |
| Tags | CPython 3.14 CPython 3.14 free-threading Linux glibc 2.28+ x86-64 |
|
SHA-256 checksum How to use checksums |
8db6a5aef22cd2a7052e5b0e0df7bc394fdbf85b7c80056cec85c57097534887
|
|
BLAKE2b-256 checksum How to use checksums |
845aa2f6724dcfd085d628b566a58952ce763c6458bfa163569d95bfc0c3fb27
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.14.8
|
Release files / meerschaum-5.0.0rc12-cp311-abi3-musllinux_1_2_x86_64.whl
| Download URL | meerschaum-5.0.0rc12-cp311-abi3-musllinux_1_2_x86_64.whl |
|---|---|
| Size | 35.6 MB |
| Tags | CPython 3.11 Linux musl 1.2+ x86-64 abi3 |
|
SHA-256 checksum How to use checksums |
1b9ea7f57876e64f3f330ad53178105f607a94ca49ac58f9d78c7cb8c4729dd0
|
|
BLAKE2b-256 checksum How to use checksums |
b70833982e21a84005a0bd6716c0f339a5503bdad344f38886a485a9c5d81509
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.14.8
|
Release files / meerschaum-5.0.0rc12-cp311-abi3-manylinux_2_28_x86_64.whl
| Download URL | meerschaum-5.0.0rc12-cp311-abi3-manylinux_2_28_x86_64.whl |
|---|---|
| Size | 35.3 MB |
| Tags | CPython 3.11 Linux glibc 2.28+ x86-64 abi3 |
|
SHA-256 checksum How to use checksums |
77b4b589e958d022617b482fd15a2ef238523b54681b136c53beb84c9bb5dee7
|
|
BLAKE2b-256 checksum How to use checksums |
8ed453aea245dab69e07fecc966aaf6dfcfb3f238076211743ba5def859982ea
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.14.8
|
Security for meerschaum 5.0.0rc12
Provenance
Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.
No provenance found
None of the files in this release were uploaded with provenance metadata.
A note on package security
PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.
To learn more about protecting yourself from malicious actors, visit our package security documentation.
