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/debInstall
Make sure PGDG and PIGSTY repo available:
pig repo add pgsql -u # add both repo and update cacheInstall 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 14Create this extension with:
CREATE EXTENSION omni_cloudevents CASCADE; -- requires omni_webUsage
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