菜单
Creates @materialize.snapshot aggregation projections in SAP CAP. Use when defining group by snapshots, sum/count aggregates, schedule options, or the materialized aspect on target entities.
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
基于 SOC 职业分类
Creates @federation.replicate consumption views for scheduled remote-to-local sync in SAP CAP. Use when copying remote OData or REST data locally, configuring schedule, delta sync, or the replicated aspect.
Registers cds-data-pipeline jobs via addPipeline with correct source and target shapes. Use when creating replicate, materialize, or move-to-service pipelines, configuring delta sync, schedules, or REST/OData sources.
Enables the cds-data-pipeline Pipeline Console UI for the /pipeline management API. Use when adding pipeline monitoring, running pipelines manually, viewing run history, inspecting source/target data, or scaffolding with cds add pipeline-console.
Registers cds-data-pipeline event hooks on DataPipelineService. Use when customizing PIPELINE.READ, PIPELINE.MAP, PIPELINE.WRITE, filtering records, or extending pipeline behavior without forking the engine.
Installs and configures cds-data-pipeline in a SAP CAP project. Use when adding the pipeline plugin, importing tracker schema, exposing the management OData service, or connecting to the pipeline engine.
Handles cross-service $expand and navigation in cds-data-federation. Use when expanding local to remote, remote to local, cross-provider mashups, navigation filters, or association renames across federated entities.
| name | snapshot-projection |
| description | Creates @materialize.snapshot aggregation projections in SAP CAP. Use when defining group by snapshots, sum/count aggregates, schedule options, or the materialized aspect on target entities. |
using from 'cds-data-pipeline/db';
namespace reporting;
@materialize.snapshot: {
schedule : '0 2 * * *',
source : { service: 'db' }
}
entity DailyCustomerRevenue as projection on sales.Orders {
key customerId,
sum(amount) as totalAmount : Decimal(15, 2),
count(*) as orderCount : Integer,
max(modifiedAt) as lastActivity : Timestamp
}
group by customerId;
source.service is the cds.requires key that executes the aggregate (typically db for local tables).
| Option | Description |
|---|---|
schedule | Cron or interval for pipeline runs |
refresh | Default full — rebuild entire snapshot each run |
name | Pipeline tracker name (default: entity name) |
source.service | Required when from ref is not Service.Entity |
materialized aspectusing { plugin.data_materialization as materialization } from 'cds-data-materialization';
entity DailyCustomerRevenue : materialization.materialized {
key customerId : String(10);
totalAmount : Decimal(15, 2);
}
Adds lastMaterializedAt and lastMaterializedBy.
Supported:
projection onas aliasesgroup by on projected keyswhere on the projectionRejected at scan time:
@federation.* on the same entityRemote OData cannot be the aggregate source. Workflow:
@federation.replicate remote entity into local table@materialize.snapshot on group by over the local table with source.service: 'db'❌ Wrong:
@materialize.snapshot: { source: { service: 'RemoteOData' } }
entity DailyRevenue as projection on remote.Orders { ... }
group by customerId;
✅ Correct — replicate first, aggregate from db.
❌ Wrong — @materialize.snapshot: { refresh: 'partial' } in annotation.
✅ Correct — full refresh in v1; use engine API for partial refresh with refresh.slice.