omni_python

pig build pkg omnigres;		# build rpm/deb

pig repo add pgsql -u   # add both repo and update cache

pig install omnigres;		# install via package name, for the active PG version
pig install omni_python;		# install by extension name, for the current active PG version

pig install omni_python -v 18;   # install for PG 18
pig install omni_python -v 17;   # install for PG 17
pig install omni_python -v 16;   # install for PG 16
pig install omni_python -v 15;   # install for PG 15
pig install omni_python -v 14;   # install for PG 14

CREATE EXTENSION omni_python CASCADE; -- requires plpython3u

# hello.py
from omni_python import pg

@pg
def hello() -> str:
    return "Hey there!"

@pg
def add(a: int, b: int) -> int:
    return a + b

CREATE EXTENSION omni_python CASCADE;
CREATE EXTENSION omni_schema CASCADE;
CREATE EXTENSION omni_vfs CASCADE;

CREATE OR REPLACE FUNCTION demo_fs() RETURNS omni_vfs.local_fs
    LANGUAGE sql AS $$ SELECT omni_vfs.local_fs('/python-files') $$;

SELECT omni_schema.load_from_fs(demo_fs());

from omni_python import pg
from omni_http import omni_httpd
from omni_http.omni_httpd import flask
from flask import Flask, jsonify, request

app = Flask('myapp')

@app.route('/employees', methods=['GET'])
def get_employees():
    employees = plpy.execute(plpy.prepare("select * from employees"))
    return json.dumps([dict(e) for e in employees])

handle = pg(flask.Adapter(app))

UPDATE omni_httpd.handlers SET query = $$select handle(request.*) from request$$;