一键在 Manus 中运行任何 Skill

loom-mirrored-database

星标2

分支1

更新时间2026年6月11日 06:41

Azure-native mirrored database in CSA Loom — replicate sources with ADF CDC / Synapse Link into ADLS Bronze Delta, never Fabric Mirroring. Call adf-client.ts + mirror-engine.ts via /api/items and /api/adf. Triggers on mirrored database, mirroring, CDC, change data capture, replication, Synapse Link, bronze landing.

安装

用 Codex 或 Claude 帮你安装复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。

在 Manus 中运行

来源

fgarofalo56

fgarofalo56/csa-inabox

打开 GitHub 仓库查看创作者相关仓库

下载

在 Manus 中运行

loom-mirrored-database — ADF CDC → ADLS Bronze Delta (the Azure-native Mirroring)

A Loom mirrored-database continuously replicates an external source (Azure SQL, Cosmos, etc.) into ADLS Bronze Delta using ADF change-data-capture (or Synapse Link copy). It is NOT Fabric Mirroring.

Clients

apps/fiab-console/lib/azure/adf-client.ts (CDC top-level resources + pipelines) and mirror-engine.ts (the orchestration that wires source → CDC → Delta).

Key behaviour:

adf-client.ts exposes the CDC + pipeline surface (listPipelines(), upsertPipeline(), runPipeline(), plus the CDC top-level resource methods) used to provision the replication.
mirror-engine.ts resolves the source, lands snapshots as Delta in the bronze container, and converts landed https DFS URLs into the Spark abfss:// form via httpsToAbfss() from cloud-endpoints.ts (sovereign-correct).

Auth

UAMI-first chain. The UAMI needs Data Factory Contributor on the factory and Storage Blob Data Contributor on the landing account (granted in bicep — the mirror task explicitly added the Blob Data Contributor grant).

BFF routes

/api/items/mirrored-database/[id]/** and /api/adf/**. The mirror-source wizard posts the source spec; the route provisions the CDC pipeline and reports real run status — { ok, data: { runId, tables: [...] } }. No mock table list.

Do / don't

DO land replicated data as Delta in bronze and register it for Synapse query.
DO use httpsToAbfss() for any Spark path — it handles the Gov DFS suffix.
DON'T call the Fabric Mirroring REST API on the default path.
DON'T leave the wizard in a stuck state — surface the real ADF run status.

Cross-links

UI parity: docs/fiab/parity/mirrored-database.md, adf-change-data-capture.md. Backend map row: mirrored-database in .claude/rules/no-fabric-dependency.md.

同仓库更多 Skills

同仓库

loom-activator

fgarofalo56/csa-inabox

Azure-native activator (Reflex) in CSA Loom — back it with an Azure Monitor scheduled-query alert (or Logic App), never Fabric Activator. Call monitor-client.ts via /api/monitor. Triggers on activator, Reflex, alert, trigger, scheduled query rule, action group, notification, data activator.

2026-06-112

loom-cloud-endpoints

fgarofalo56/csa-inabox

MUST-READ root skill for CSA Loom. Resolve every Azure endpoint host and AAD scope from cloud-endpoints.ts instead of hard-coding management.azure.com / kusto.windows.net / dfs.core.windows.net. Triggers on sovereign cloud, GCC, GCC-High, DoD, IL5, endpoint, hostname, ARM, scope, token audience, government cloud.

2026-06-112

loom-data-pipeline

fgarofalo56/csa-inabox

Azure-native data pipeline in CSA Loom — back it with a Synapse pipeline (or ADF), never a Fabric Data pipeline. Call synapse-dev-client.ts + adf-client.ts via /api/adf and /api/synapse. Triggers on data pipeline, copy activity, dataflow, orchestration, trigger, integration runtime, ADF, Synapse pipeline.

2026-06-112

loom-eventhouse-kql

fgarofalo56/csa-inabox

Azure-native Eventhouse/KQL in CSA Loom — call Azure Data Explorer (ADX) via kusto-client.ts + kusto-arm-client.ts, never Fabric RTI. Use /api/adx routes. Triggers on KQL, Eventhouse, ADX, Kusto, real-time intelligence, KQL database, KQL dashboard, ingestion mapping, materialized view, RLS.

2026-06-112

loom-eventstream

fgarofalo56/csa-inabox

Azure-native eventstream in CSA Loom — back it with Azure Event Hubs (+ Stream Analytics for processing), never Fabric Eventstream. Call eventhubs-client.ts + stream-analytics-client.ts via /api/eventhubs. Triggers on eventstream, Event Hubs, streaming, real-time ingestion, consumer group, Stream Analytics, capture, schema registry.

2026-06-112

loom-items-bff

fgarofalo56/csa-inabox

The generic CSA Loom item BFF contract. Every item type exposes /api/items/<type>/<id>/<action> returning { ok, data, error } with a real backend call and honest config gates — never mock arrays or dead handlers. Triggers on BFF route, API route, item action, session validation, config gate, response shape, NextResponse, no-vaporware.

2026-06-112

name	loom-mirrored-database
description	Azure-native mirrored database in CSA Loom — replicate sources with ADF CDC / Synapse Link into ADLS Bronze Delta, never Fabric Mirroring. Call adf-client.ts + mirror-engine.ts via /api/items and /api/adf. Triggers on mirrored database, mirroring, CDC, change data capture, replication, Synapse Link, bronze landing.
allowed-tools	Read, Grep, Glob, Bash

loom-mirrored-database — ADF CDC → ADLS Bronze Delta (the Azure-native Mirroring)

Clients

apps/fiab-console/lib/azure/adf-client.ts (CDC top-level resources + pipelines) and mirror-engine.ts (the orchestration that wires source → CDC → Delta).

Key behaviour:

adf-client.ts exposes the CDC + pipeline surface (listPipelines(), upsertPipeline(), runPipeline(), plus the CDC top-level resource methods) used to provision the replication.
mirror-engine.ts resolves the source, lands snapshots as Delta in the bronze container, and converts landed https DFS URLs into the Spark abfss:// form via httpsToAbfss() from cloud-endpoints.ts (sovereign-correct).

Auth

BFF routes

Do / don't

DO land replicated data as Delta in bronze and register it for Synapse query.
DO use httpsToAbfss() for any Spark path — it handles the Gov DFS suffix.
DON'T call the Fabric Mirroring REST API on the default path.
DON'T leave the wizard in a stuck state — surface the real ADF run status.

Cross-links

UI parity: docs/fiab/parity/mirrored-database.md, adf-change-data-capture.md. Backend map row: mirrored-database in .claude/rules/no-fabric-dependency.md.