Configuring external storage#
AIDB pipelines can read from two types of data source:
Postgres tables — reference a table directly by name using the
sourceparameter inaidb.create_pipeline(). See Creating pipelines .External storage volumes — connect S3-compatible object stores, Google Cloud Storage, Azure, or local file systems via PGFS. The rest of this page covers how to set this up.
External storage is accessed through the Postgres File System (PGFS) extension, which maps external storage into Postgres as storage locations. AIDB then wraps each storage location in a volume that pipelines reference by name. A volume is a foreign table , so you can list, read, write, and delete objects with standard SQL.
How it works#
Connecting external storage to an AIDB pipeline involves two objects:
PGFS storage location — Defines the external storage provider: its URI, credentials, and connection options. Created with pgfs.create_storage_location() .
AIDB volume — A foreign table that exposes the contents of a PGFS storage location as rows. Stores the data format (
Text,Image,Pdf) and an optional sub-path. Created withaidb.create_volume().
Once a volume exists, reference it as the source in
aidb.create_pipeline() exactly as you would a Postgres table, or
query it directly with SQL.
!!!note The PGFS extension must be installed before creating storage locations. See Configuring AIDB .
Step 1: Creating a storage location#
Use pgfs.create_storage_location() to define the connection to
external storage. The url parameter identifies the storage backend
and path; the options JSONB object carries provider-specific
settings such as region; the credentials JSONB object carries
authentication secrets such as access keys.
!!!note Explicit credentials in the credentials parameter aren’t the
only way to authenticate. If you omit them, S3, Azure, and GCS storage
locations fall back to the respective cloud provider’s own native
credential resolution (IAM roles, managed/workload identity, instance
metadata, Application Default Credentials) — useful when Postgres is
already running with a cloud identity attached, so there’s no secret to
store at all. See the PGFS documentation for details.
S3-compatible object store#
- - Private S3 bucket with credentials
SELECT pgfs.create_storage_location(
name => my_s3_location,
url => s3://my-bucket/my-folder,
options => {"region": "us-east-1"},
credentials => {"access_key_id": "<key>", "secret_access_key": "<secret>"}
-- or omit the credentials argument to use the cloud providers native credential chain (IAM role, managed identity, etc.) instead
);
- - Public S3 bucket (no credentials required)
SELECT pgfs.create_storage_location(
name => my_public_bucket,
url => s3://aidb-rag-app,
options => {"region": "eu-central-1", "skip_signature": "true"}
);
Local file system#
For local file system access, declare the allowed base paths in
postgresql.conf before creating the storage location. PGFS restricts
access to these paths for security.
# postgresql.conf
pgfs.allowed_local_fs_paths = /tmp/pgfs
After restarting Postgres, create the storage location using a
file:// URI:
SELECT pgfs.create_storage_location(
name => local_tmp_pgfs,
url => file:///tmp/pgfs/
);
For full details on storage location options for S3, GCS, and Azure, see the PGFS documentation .
!!!Note Restricting egress to your object store PGFS supports an
optional outbound allowlist (pgfs.egress_allowlist , with
edb.egress_allowlist as a shared fallback) that restricts which
hosts PGFS is allowed to reach when accessing storage locations. This is
independent of AIDB’s allowlist for model-provider traffic; both can be
configured together. See PGFS — Network egress and AIDB — Network egress .
Step 2: Creating a volume#
Use aidb.create_volume() to create a foreign table that exposes a
PGFS storage location to AIDB. The volume name is the foreign-table name
that you reference in pipelines and SQL queries.
SELECT aidb.create_volume(
name => my_volume,
server_name => my_s3_location,
path => /,
data_format => Text
);
Parameters:
Parameter |
Description |
|---|---|
name |
Unique name for the volume. Must be a valid unquoted PostgreSQL identifier (lowercase, starts with a letter or underscore, contains only letters, digits, and underscores — no dashes or spaces). Used as the foreign-table name. |
server_name |
Name of the PGFS storage location to attach. |
path |
Optional sub-path within the storage location. See Path handling below. |
data_format |
The type of data in this volume. One of Text, Image, or Pdf. Pipelines use this to choose the correct parsing step. |
!!!note data_format is metadata — it tells AIDB how to treat the
objects, but doesn’t filter them. Ensure the volume only contains
objects of the declared format.
Path handling#
The path argument is canonicalized at creation time: any leading and
trailing slashes are stripped, then exactly one trailing slash is
appended. This means the following all store as foo/ :
foo/foofoo//foo/
Passing NULL or / stores as / , which targets the storage
location’s root. The canonical value is what you see in aidb.volumes
and what’s used to compute object keys.
Example: PDFs in S3#
SELECT pgfs.create_storage_location(
pdf_bucket,
s3://my-docs-bucket,
options => {"region": "us-east-1"},
credentials => {"access_key_id": "<key>", "secret_access_key": "<secret>"}
-- or omit the credentials argument to use the cloud providers native credential chain instead
);
SELECT aidb.create_volume(pdf_volume, pdf_bucket, /, Pdf);
Example: Images in a local directory#
SELECT pgfs.create_storage_location(local_tmp_pgfs, file:///tmp/pgfs/);
SELECT aidb.create_volume(ocr_input_volume, local_tmp_pgfs, ocr_input/, Image);
Step 3: Using the volume as a pipeline source#
Set the source parameter in aidb.create_pipeline() to the volume
name. Volume sources work the same as table sources from the pipeline’s
perspective:
SELECT aidb.create_pipeline(
name => my_pdf_pipeline,
source => pdf_volume,
step_1 => ParsePdf,
step_2 => ChunkText,
step_3 => KnowledgeBase,
step_3_options => aidb.knowledge_base_config(bert_local, Text)
);
See Create a pipeline for a full walkthrough.
Managing volumes#
Listing volumes#
List all volumes via the aidb.volumes view:
SELECT * FROM aidb.volumes;
__OUTPUT__
schema | volume | storage_location | path
- -------+--------------+------------------+---------------
public | pdf_volume | pdf_bucket | /
public | text_bucket | text_bucket | aidb-rag-app/
(2 rows)
The view returns four columns: schema , volume ,
storage_location , and path (canonicalized).
Deleting a volume#
SELECT aidb.delete_volume(my_volume);
!!!note Deleting a PGFS storage location also deletes all volumes built on top of it.
Accessing volume contents with SQL#
A volume is a foreign table backed by PGFS, so the storage location’s objects are exposed as rows. The columns are:
Column |
Type |
Description |
|---|---|---|
key |
TEXT |
Object key (file path) relative to the volume's path. |
size |
BIGINT |
Object size in bytes. |
last_modified |
TIMESTAMPTZ |
Last-modified timestamp reported by the storage backend. |
e_tag |
TEXT |
Entity tag (ETag) reported by the storage backend, when available. |
body |
BYTEA |
Object contents. Only populated when the query includes WHERE key = '<exact-key>' (see note below). |
!!!note The body column is only fetched when you select it and
filter on a single key with WHERE key = '...' . Selecting body
without a key filter returns NULL — this is a safeguard against
accidentally downloading every object in the volume.
Listing objects in a volume#
SELECT key, size, last_modified
FROM my_volume
ORDER BY key;
__OUTPUT__
key | size | last_modified
- -----------------------+------+------------------------
Test 1.html | 1093 | 2026-05-14 15:49:32+00
Test 2.html | 1563 | 2026-05-14 15:50:02+00
Test 3.html | 1395 | 2026-05-14 15:49:32+00
(3 rows)
LIMIT is pushed down to the storage backend, so it’s safe to peek at
large buckets:
SELECT key, size FROM my_volume LIMIT 5;
Reading a single object#
Filter on the exact key to fetch the object body:
- - Read a binary file as BYTEA
SELECT body FROM my_volume WHERE key = report.pdf;
- - Read a text file as text
SELECT convert_from(body, utf8)
FROM my_volume
WHERE key = notes.txt;
Writing, overwriting, and deleting objects#
Volumes support standard INSERT , UPDATE , and DELETE .
body is BYTEA ; cast text to bytea as needed.
- - Upload a new object
INSERT INTO my_volume (key, body)
VALUES (hello.txt, Hello, world::bytea);
- - Overwrite an existing object
UPDATE my_volume
SET body = Hello again::bytea
WHERE key = hello.txt;
- - Delete an object
DELETE FROM my_volume WHERE key = hello.txt;
!!!note Object-store writes aren’t transactional. A successful
INSERT , UPDATE , or DELETE isn’t rolled back if the
surrounding PostgreSQL transaction aborts.
Renaming a key (UPDATE my_volume SET key = ... ) isn’t supported.