Реиндексирование и нулевой простой

AACsearch uses a versioned collection + alias strategy to perform schema migrations and full reindexes without search downtime. Queries always target the alias (a stable name), while versioned collections are swapped underneath.

The alias-swap model

Every search index uses two AACSearch names:

alias:       org123_products        ← stable, used by all search queries
collection:  org123_products_v1     ← current versioned collection (serving traffic)

When a reindex is triggered:

sequenceDiagram
    autonumber
    participant API as Reindex trigger
    participant DB as Postgres source-of-truth
    participant V1 as Collection v1 (live)
    participant V2 as Collection v2 (building)
    participant Alias as Alias (atomic pointer)
    Note over Alias,V1: Before — queries hit v1
    API->>V2: CREATE collection with new schema
    DB-->>V2: bulk-import all documents
    V2->>V2: verify doc count ≈ expected
    par parallel reads
        Note right of V1: queries still hit v1 — zero downtime
    end
    API->>Alias: ATOMIC SWAP alias → v2
    Note over Alias,V2: After — queries hit v2; v1 kept for rollback until next reindex

Step 4 (alias swap) is atomic in AACSearch. Queries continue hitting the old version during steps 1–3 and seamlessly target the new version after step 4 — with zero downtime.

When to reindex

Trigger reindex

Via dashboard

1. Navigate to Search → Indexes → select your index
2. Click the Reindex button in the index settings
3. Monitor progress in the import jobs panel

Via oRPC

const job = await orpc.search.reindex.call({
	organizationId: "org_...",
	indexSlug: "products",
});
// Returns: { jobId, status: "queued" }

Via Connector API (admin)

POST /api/v1/indexes/{indexSlug}/reindex
Authorization: Bearer aa_admin_your_key

Monitor reindex progress

Check the import job status:

const jobs = await orpc.search.importJobs.call({
	organizationId: "org_...",
	indexSlug: "products",
});

const activeJob = jobs.find((j) => j.type === "reindex" && j.status === "running");
// activeJob.processedItems / activeJob.totalItems → progress

In the dashboard, the Import Jobs tab shows reindex progress with a progress bar.

Schema updates

Before reindexing, update the collection schema:

await orpc.search.schema.update.call({
	organizationId: "org_...",
	indexSlug: "products",
	fields: [
		// Add a new field
		{ name: "tags", type: "string[]", facet: true, optional: true },
	],
});

This updates the schema definition stored in AACsearch. The actual search index schema is updated during the next reindex (schema changes are not applied in-place to avoid downtime).

Quota impact

Reindex re-ingests all documents. For a 50K-product catalog, a reindex consumes 50K search units. Plan your reindex schedule around your monthly quota.

Rollback

If the new collection has problems, rollback by pointing the alias back to the previous version:

await orpc.search.reindex.call({
	organizationId: "org_...",
	indexSlug: "products",
	rollback: true, // swaps alias back to the previous version
});

The previous version (v{N-1}) is preserved until the next successful reindex.

Implementation details

The reindex implementation is in packages/search/lib/reindex.ts (exported as reindexCollection).

Key behaviors:

• Versioned collection name: {orgShortId}_{slug}_v{nextVersion}
• Alias swap: AACSearch.aliases.upsert(alias, { collection_name: newCollectionName })
• Document source: re-drains the full document set from the ingest buffer or a snapshot
• Partial failure: if import fails before swap, old version continues serving; new version is deleted

The function is called from searchRouter.reindex procedure in packages/api/modules/search/procedures/reindex.ts.