GEA-Program
Downhole gauge monitoring for production operations: the program takes a well's historian data and returns the reports a client engineer reads, in the outline and language of a production-operations scope of work.
Every number in every report is recomputed from the source data at generation time. Reports are gated for vocabulary: the program's internal register never reaches a client document. Nothing unmeasured is ever reported as met.
What it does
- Canonical measurement record (
gea/sample_record.py): one record shape for every sample - tag, UTC timestamp, value, unit, quality flag, the rule and limit that fired, source layer, ingest timestamp. Quality rules: RANGE / ROC / FLATLINE / SPIKE / STALE / GAP; ranges from the gauge datasheet, cited. - Gauge drift and reconciliation (
reconciler.py,drift_monitor.py): the live pressure series against the well baseline; classification with the numbers beside it; scheduled evaluation log; CURRENT / STALE; re-fit change log with before/after coefficients; approve -> apply -> re-evaluate; SLA clocks; annual re-fit cap. - Accuracy statement (
accuracy_statement.py): MAPE with a seeded bootstrap 90 % CI; the band read at the conservative end of the interval. - Well-test validation (
well_test_validation.py): stable-period detection with the client-agreed criteria in a file (hashed on every report), reason codes naming the failing value, virtual rates, two-level approval trail. - Alarm management (
alarm_engine.py): setpoint / deadband / on-delay state machine, event log, ISA-18.2-style KPIs printed against their targets. - Model cards (
model_card.py): one card per model - inputs with sources, settings with basis, calibration data with provenance, recomputed evaluation, limitations, re-fit history, component hashes. - Store-and-forward (
store_forward.py): 72 h edge buffer, chronological rate-controlled replay, duplicate suppression, per-record latency. - Configuration versioning, SBOM, monthly SLA, FAT/SAT
(
config_versioning.py,sbom.py,sla_report.py,fat_sat.py). - Live protocol ports (
live_ports.py,opcua_port.py,mqtt_port.py): read-only OPC UA client (read and subscribe) and MQTT subscriber (plain number, JSON and Sparkplug B payloads, Sparkplug decoded with no protobuf library); every message becomes a measurement record with its source timestamp, ingest timestamp and quality flag; every session can be recorded and replayed offline. See Live data below. - Dashboard (
dashboard.py): tiles, well ranking, alarm wall, drill-down to every report; light and dark; status is always an icon with a label. - Survey track (
earth_model.py,strata_join.py,inverse_engine.py,blind_harness.py,rock_inventory.py,forward_model.py, ...): strata property estimation over a public co-located library, blind-scored on every run.
Quick start
pip install -e .
gea quickstart # a real catalogue well -> its reports -> the dashboard; the KTB strata survey
gea survey mywell.las # a LAS file in, one strata report out
gea dashboard --catalog-well volve_f12_f14_production_excerpt:15/9-F-12:10000 --td 10500 --out dashboard
gea client-report --report accuracy --out client_report
gea model-cards --out model_cards
gea sbom --out sbom
gea accept # the product gate (172 checks)
gea guide # the click-by-click tester guide (docs/TESTER_GUIDE.md)
gea gui # the desktop window (pip install "gea-program[desktop]")
gea is the front door (gea/cli.py); every other subcommand passes through to
python -m gea. PATH-proof form: python -m gea.cli .... Open dashboard/index.html.
Live data
The engine reads live data through two protocol ports. Both are read-only,
both map only what the site declares (a tag map the client owns; an empty map
is declined), and both write every received message to a JSON-lines recording
that --replay turns back into records without a connection - which is how a
site session is reproduced offline and how the mapping logic is tested.
pip install "gea-program[live]" # asyncua + paho-mqtt (or [opcua] / [mqtt] alone)
gea opcua --write-example-config opcua.json # edit: endpoint, security, credential env names, nodes
gea opcua --config opcua.json --read-once --out opc # one read of every mapped node
gea opcua --config opcua.json --seconds 60 --record opc/session.jsonl --out opc --stream-csv opc/stream.csv
gea mqtt --write-example-config mqtt.json # edit: broker, TLS, credential env names, topics
gea mqtt --config mqtt.json --seconds 60 --record mq/session.jsonl --out mq --stream-csv mq/stream.csv
gea mqtt --config mqtt.json --replay mq/session.jsonl --out mq_replay # no broker needed
gea ingest --file mq/stream.csv # the stream CSV feeds the historian port like any other
| port | transport | quality | timestamps |
|---|---|---|---|
opcua |
opc.tcp, read + subscribe; Basic256Sha256 SignAndEncrypt when a certificate and key are given | StatusCode severity bits: Good -> GOOD, Uncertain -> STALE, Bad -> GAP (value withheld); the rule names the code | source timestamp, else server timestamp, else arrival; ingest stamped at arrival |
mqtt |
MQTT v5 / v3.1.1, TLS optional, QoS per topic; +/# wildcards |
number: GOOD or GAP (unparseable, reason kept); JSON: value/time/quality paths and the list of good values; Sparkplug B: is_null -> GAP, Quality property != 192 -> STALE |
JSON time path (ISO / epoch s / epoch ms), Sparkplug metric timestamp, else arrival |
Credentials never sit in a config file: the file names the environment variables
that hold them (GEA_OPCUA_USER, GEA_MQTT_PASSWORD, ...). Sparkplug B aliases
are learned from any NBIRTH/DBIRTH on the matching edge node, so alias-only DDATA
resolves. The example configs are in docs/examples/; the acceptance suite
section AB covers the codec, the mappings, the quality rules, replay and the
hand-off to the store-and-forward buffer, and runs a live in-process OPC UA
loopback wherever asyncua is installed.
Layout
gea/ the package: engines, record layer, reports, monitor, dashboard, cli, shell, acceptance suite
gea/catalog/ 52 public archive entries, each with a provenance file
docs/ TESTER_GUIDE.md, REQUIREMENTS_MATRIX.md (the scope-of-work mirror that shaped the reports), examples/ (port configs),
SESSION_LOG.md (the working record, session by session),
commercial/ (pilot proposal, bench readiness, commercial use), HISTORY.md (the ship-by-ship record)
tools/ standalone_check.py (the self-contained guard: imports, text, metadata; run by ci and ship.ps1)
CHANGELOG.md per-release summary (a tag ships only with its section); SHIP_LOG.md is written by ship.ps1
tests/ pytest wrapper around the acceptance suite and the standalone check
Basis
GEA-Program is a self-contained package: every module imports only the
standard library, numpy, the declared optional extras and the package itself,
and tools/standalone_check.py (run by CI and by ship.ps1) fails the build
if that ever changes or if a tracked file names another program. The physics
is on standard constants - CODATA 2018 G, standard gravity 9.80665 m/s2, the
IUGG mean Earth radius - and the rock inventory carries seventeen published
density anchors and Vp ranges with their citations (Telford, Geldart and
Sheriff; Schon). Every catalogue entry under gea/catalog/ has a provenance
file naming its public source.
Two statements the product carries on its own model cards: the gauge aging envelope's lower bound is an engineering model with no field validation on record, and five of the fourteen back-tested strata quantities are NOT ACCEPTABLE at the 95 % target. Both are printed, never claimed otherwise.
Shipping
.\ship.ps1 (PowerShell) gates, commits, tags and pushes in one screen: version in
pyproject.toml must equal gea.__version__ (-Bump x.y.z sets both), the tag must
not exist anywhere, every version in SHIP_LOG.md must have its tag, python -m gea accept must be green, SHIP_MESSAGE.txt must start with the tag; then commit, tag,
push, and the remote tag must be seen before SHIPPED is printed. CHANGELOG.md must carry a
section headed by the tag, and tools/standalone_check.py must report no findings. -DryRun runs every
check and changes nothing; -NoPush stops after the local tag.
Publishing to PyPI
The name gea-program is free on PyPI as of 2026-09-29; a PyPI project is created by
its first upload, there is nothing to "start" beforehand except the trusted publisher.
One-time setup, before the first tag is pushed: sign in to PyPI -> your account ->
Publishing -> "Add a new pending publisher": project name gea-program, owner
Daniel8Murphy0007, repository GEA-Program, workflow release-to-pypi.yml,
environment pypi. Then in GitHub -> Settings -> Environments create pypi. From then
on .\ship.ps1 pushes the tag and .github/workflows/release-to-pypi.yml gates, builds,
verifies the wheel and publishes; the package page is
https://pypi.org/project/gea-program/ after the first successful run.
Licence
Mozilla Public License 2.0 (MPL-2.0); see LICENSE. Every source file carries the MPL-2.0
header (Exhibit A). Copyright (c) 2026 Daniel T. Murphy.
Metadata
Release files for gea-program 0.2.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| gea_program-0.2.0.tar.gz | 508.4 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| gea_program-0.2.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 1.1 MB
Release files / gea_program-0.2.0.tar.gz
| Download URL | gea_program-0.2.0.tar.gz |
|---|---|
| Size | 508.4 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
5bf9146ba0a63b5f68a3d74e83d1bd33665d15f572028273a818d666724fad99
|
|
BLAKE2b-256 checksum How to use checksums |
8e1d98f537e3f07480fe42abad63811fa0851e4c6b1a37f7e622195bb0a040f7
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/7.0.0 CPython/3.13.14
|
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.
PyPI Publish Attestation
PyPI verified that this artifact, at this checksum, originated from the publisher listed below.
Signed by GitHub Actions, verified by PyPI on Sep 30, 2026.
Transparency logRelease files / gea_program-0.2.0-py3-none-any.whl
| Download URL | gea_program-0.2.0-py3-none-any.whl |
|---|---|
| Size | 589.3 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
ceb539d3abc849232058db100f539c43d15d8de6dc31270c5a79916a502155de
|
|
BLAKE2b-256 checksum How to use checksums |
91f21e849f5b9c59706714678ab26eddaadfac62a69e20a644f3f6a10de26100
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/7.0.0 CPython/3.13.14
|
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.
PyPI Publish Attestation
PyPI verified that this artifact, at this checksum, originated from the publisher listed below.
Signed by GitHub Actions, verified by PyPI on Sep 30, 2026.
Transparency log