omni_aws

概览

版本

构建

您可以使用 pig build 命令构建 omnigres 扩展的 RPM / DEB 包：

pig build pkg omnigres         # 构建 RPM / DEB 包

安装

您可以直接安装 omnigres 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：

pig repo add pgsql -u          # 添加仓库并更新缓存

使用 pig 或者是 apt/yum/dnf 安装扩展：

• 安装
• pig
• dnf
• apt

pig install omnigres;          # 当前活跃 PG 版本安装

pig ext install -y omnigres -v 18  # PG 18
pig ext install -y omnigres -v 17  # PG 17
pig ext install -y omnigres -v 16  # PG 16
pig ext install -y omnigres -v 15  # PG 15
pig ext install -y omnigres -v 14  # PG 14

dnf install -y omnigres_18       # PG 18
dnf install -y omnigres_17       # PG 17
dnf install -y omnigres_16       # PG 16
dnf install -y omnigres_15       # PG 15
dnf install -y omnigres_14       # PG 14

apt install -y postgresql-18-omnigres   # PG 18
apt install -y postgresql-17-omnigres   # PG 17
apt install -y postgresql-16-omnigres   # PG 16
apt install -y postgresql-15-omnigres   # PG 15
apt install -y postgresql-14-omnigres   # PG 14

创建扩展：

CREATE EXTENSION omni_aws CASCADE;  -- 依赖: omni_httpc, pgcrypto, omni_xml, omni_web

用法

omni_aws: Amazon Web Services API（S3）

omni_aws 扩展为 PostgreSQL 提供 S3 兼容的 API 函数。

S3 API 函数

s3_create_bucket(bucket, region) – 创建 S3 存储桶。

s3_list_objects_v2(bucket, path, continuation_token, delimiter, encoding_type, fetch_owner, max_keys, start_after, region) – 列出存储桶中的对象，支持分页。

s3_put_object(bucket, path, payload, content_type, region) – 上传对象。默认内容类型为 application/octet-stream。

执行

单个请求：

SELECT * FROM omni_aws.aws_execute(
    access_key_id => 'AKID',
    secret_access_key => 'SECRET',
    request => omni_aws.s3_put_object('my-bucket', '/path/to/file', 'content'::bytea)
);

批量请求： 将 requests 作为数组传入以实现高效批量操作。返回带 error 列的表。

预签名 URL

SELECT omni_aws.s3_presigned_url(
    bucket => 'my-bucket',
    path => '/my-file',
    access_key_id => 'AKID',
    secret_access_key => 'SECRET',
    expires => 604800,  -- 7 天（默认）
    region => 'us-east-1'
);

自定义端点

• DigitalOcean Spaces： digitalocean_s3_endpoint()
• 通用端点： s3_endpoint(url)，支持 ${region} 和 ${bucket} 变量，适用于 MinIO 等兼容服务