semvec/pypi-packages huggingface dataset:
dbqueue 0.1.0
Change Data Capture from PostgreSQL WAL to RabbitMQ
Requires Python: >=3.10

# dbqueue

A lightweight, modular, and reliable CDC (Change Data Capture) library based on **PostgreSQL WAL → RabbitMQ**.

- **Logical Replication:** Captures changes instantly via PostgreSQL WAL (Write-Ahead Log).
- **RabbitMQ Integration:** Automatically routes changes to a RabbitMQ exchange.
- **Robust:** Includes automatic reconnection and exponential backoff strategies against connection drops.
- **Pluggable:** Support for `wal2json` or `pgoutput` (Postgres 10+ native) plugins.

## Requirements

- Python 3.10+
- PostgreSQL 10+ (`wal_level = logical` must be set)
- RabbitMQ

## Installation

```bash
pip install dbqueue
```

## Usage

```python
from dbqueue import DBQueueWatcher

def main():
    watcher = DBQueueWatcher(
        db_dsn="postgresql://user:pass@localhost:5432/dbname",
        rabbit_url="amqp://guest:guest@localhost:5672/",
        slot_name="my_cdc_slot",
        publication="my_cdc_pub",
        event_format="debezium_like" # or "simple"
    )

    # You can also use it as a consumer if you wish
    @watcher.on_insert("users")
    def handle_user_insert(event):
        print(f"New user: {event['after']}")

    # Publishes and runs defined handlers
    watcher.start()

if __name__ == "__main__":
    main()
```

## Postgres Settings

Make sure the following setting is present in `postgresql.conf`:

```ini
wal_level = logical
```
flowtube 1.2.1
A Python package for transport and diffusion calculations in cylindrical flow reactors
Requires Python: >=3.7
Keywords: flow reactor, diffusion, transport, coated wall reactor, aerosol, atmospheric chemistry

# flowtube Package
[![PyPI Version](https://img.shields.io/pypi/v/flowtube.svg)](https://img.shields.io/pypi/v/flowtube.svg?cacheSeconds=3600)
[![License: MIT](https://cdn.prod.website-files.com/5e0f1144930a8bc8aace526c/65dd9eb5aaca434fac4f1c34_License-MIT-blue.svg)](/LICENSE)
[![Tests](https://github.com/c-pedersen/flowtube/actions/workflows/ci.yml/badge.svg?branch=main)](https://github.com/c-pedersen/flowtube/actions/workflows/ci.yml)
[![codecov](https://codecov.io/gh/c-pedersen/flowtube/branch/main/graph/badge.svg?ts=20251106)](https://codecov.io/gh/c-pedersen/flowtube)
[![Documentation Status](https://readthedocs.org/projects/flowtube/badge/?version=latest)](https://flowtube.readthedocs.io/en/latest/?badge=latest)

A Python package for transport and diffusion calculations in cylindrical
flow reactors using the KPS method published in Knopf et al., Anal. 
Chem., 2015. The package is currently designed for coated wall reactor 
(CWR) and boat reactor analysis with plans to support aerosol flow 
reactors in future versions.

Author: Corey Pedersen 

## Features
Flow Calculations: Flow rates, velocities, residence times, and Reynolds 
numbers

Transport Properties: Dynamic viscosity and density

Diffusion Analysis: Binary diffusion coefficients, Péclet numbers, and 
mixing parameters

Uptake Modeling: Diffusion correction factors and uptake coefficient 
calculations

Support for Inserts: Handles coated cylindrical inserts within flow 
tubes

Support for Boats: Handles boat reactors which are placed in side of a 
flow tube and filled with an analyte solution.

## Scientific Applications
This package is designed for atmospheric chemistry and aerosol research,
 particularly for:
- Heterogeneous reaction kinetics studies
- Uptake coefficient measurements
- Flow reactor design and optimization
- Transport phenomena analysis in laminar flow systems

## Installation

```bash
pip install flowtube
```

## Acronyms
`sccm = standard cubic centimeter per minute` <br>
`FT = flow tube` <br>
`FR = flow rate` <br>
`MR = mixing ratio` <br>
`CWR = coated wall reactor` <br>

## Assumptions
KPS method assumptions (Knopf et al., 2015):
1. The interacting gas species is a trace gas in the bulk flow
2. Laminar flow is established in the flow reactor
3. The gas temperature and viscosity are homogeneous
4. The axial diffusion velocity is negligible compared to bulk flow 
    velocity
5. The amount of gas species taken up is small compared to its reservoir
6. There is an absence of gas-phase reactions impacting gas species 
    concentration

## Bibliography (more citations within package files)
Knopf, D.A., Pöschl, U., Shiraiwa, M., 2015. Radial Diffusion and 
Penetration of Gas Molecules and Aerosol Particles through Laminar Flow 
Reactors, Denuders, and Sampling Tubes. Anal. Chem. 87, 3746–3754. 
https://doi.org/10.1021/ac5042395