Metadata-Version: 2.4
Name: onestep-postgres
Version: 0.1.0
Summary: PostgreSQL connector plugin for onestep.
License: MIT
Requires-Python: >=3.9
Requires-Dist: onestep>=1.4.2
Requires-Dist: psycopg[binary]>=3.2.0
Requires-Dist: sqlalchemy>=2.0.0
Provides-Extra: dev
Requires-Dist: pytest>=8.0.0; extra == 'dev'
Provides-Extra: test
Requires-Dist: pytest>=8.0.0; extra == 'test'
Description-Content-Type: text/markdown

# onestep-postgres

PostgreSQL connector plugin for onestep.

Install it with:

```bash
pip install onestep-postgres
```

YAML resources are available after the plugin is installed:

```yaml
resources:
  pg:
    type: postgres
    dsn: "${POSTGRES_DSN}"

  cursor:
    type: postgres_cursor_store
    connector: pg

  users:
    type: postgres_incremental
    connector: pg
    table: users
    key: id
    cursor: [updated_at, id]
    state: cursor

  processed:
    type: postgres_table_sink
    connector: pg
    table: processed_users
    mode: upsert
    keys: [id]
```

The first version supports table queues, incremental polling, table sinks, and
SQLAlchemy-backed state/cursor stores. It does not support PostgreSQL logical
replication or CDC.
