omni_cloudevents

omni_cloudevents

omnigres : CloudEvents support

Overview

ID Extension Package Version Category License Language
2943
omni_cloudevents
omnigres
0.1.0
FEAT
Apache-2.0
C
Attribute Has Binary Has Library Need Load Has DDL Relocatable Trusted
----dt-
No
No
No
Yes
no
yes
Relationships
Schemas omni_cloudevents
Requires
omni_web
Need By
omni_email
omni_schema
omni_test
Siblings
omni
omni_auth
omni_aws
omni_containers
omni_credentials
omni_email
omni_http
omni_httpc
omni_httpd
omni_id
omni_json
omni_kube
omni_ledger
omni_manifest
omni_mimetypes
omni_os
omni_polyfill
omni_python
omni_regex
omni_rest
omni_schema
omni_seq
omni_service
omni_session
omni_sql
omni_sqlite
omni_test
omni_txn
omni_types
omni_var
omni_vfs
omni_vfs_types_v1
omni_web
omni_worker
omni_xml
omni_yaml

Packages

Type Repo Version PG Major Compatibility Package Pattern Dependencies
EXT
PIGSTY
0.1.0
18
17
16
15
14
omnigres omni_web
RPM
PIGSTY
0.1.0
18
17
16
15
14
omnigres_$v -
DEB
PIGSTY
0.1.0
18
17
16
15
14
postgresql-$v-omnigres -
Linux / PG PG18 PG17 PG16 PG15 PG14
el8.x86_64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
el8.aarch64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
el9.x86_64
MISS
PIGSTY 20250507
PIGSTY 20250507
PIGSTY 20250507
PIGSTY 20250507
el9.aarch64
MISS
PIGSTY 20250507
PIGSTY 20250507
PIGSTY 20250507
PIGSTY 20250507
el10.x86_64
MISS
MISS
MISS
MISS
MISS
el10.aarch64
MISS
MISS
MISS
MISS
MISS
d12.x86_64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
d12.aarch64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
d13.x86_64
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
d13.aarch64
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
u22.x86_64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
u22.aarch64
MISS
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
PIGSTY 20250120
u24.x86_64
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
u24.aarch64
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108
PIGSTY 20251108

Source

pig build pkg omnigres;# build rpm/deb

Install

Make sure PGDG and PIGSTY repo available:

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

Install this extension with pig:

pig install omnigres;# install via package name, for the active PG version pig install omni_cloudevents;# install by extension name, for the current active PG version  pig install omni_cloudevents -v 18; # install for PG 18 pig install omni_cloudevents -v 17; # install for PG 17 pig install omni_cloudevents -v 16; # install for PG 16 pig install omni_cloudevents -v 15; # install for PG 15 pig install omni_cloudevents -v 14; # install for PG 14

Create this extension with:

CREATE EXTENSION omni_cloudevents CASCADE; -- requires omni_web

Usage

omni_cloudevents: CloudEvents support

The omni_cloudevents extension enables creation, validation, and publication of standardized CloudEvents from SQL. It is a templated extension.

Setup

SELECT omni_cloudevents.instantiate(schema => 'omni_cloudevents'); SET search_path TO omni_cloudevents, public;

Creating Events

SELECT cloudevent(  id => gen_random_uuid(),  source => 'https://service.com/endpoint',  type => 'user.login' );

Optional parameters: datacontenttype, dataschema, subject, ts (defaults to now), data (any PG type), specversion (default 1.0).

Publishing Events

SELECT publish(  cloudevent(  id => gen_random_uuid(),  source => 'https://api.yourservice.com/sys',  type => 'file.uploaded',  data => 'data-lake-bucket-123'::text  ) );

Published events are persisted in the cloudevents_egress table.

NOTICE Publisher

SELECT omni_cloudevents.create_notice_publisher(); -- To observe uncommitted events: SELECT omni_cloudevents.create_notice_publisher(publish_uncommitted => true); -- Delete a publisher: SELECT omni_cloudevents.delete_publisher(name);

Events generate JSON-formatted NOTICE messages with full event details.

Last updated on