Erstellt Staging-View und optional External Table
Erstellt eine Staging-View für eine Entity mit Hash-Key-Berechnungen. Nutze diesen Befehl, wenn du eine neue Datenquelle in die Data Vault 2.0 Staging-Layer integrieren möchtest.
/plugin marketplace add fellnerd/claude-marketplace/plugin install datavault@dimetrics-marketplaceDu erstellst die Staging-Layer für eine neue Entity. Folge diesem Workflow:
Prüfe ob die External Table existiert:
Tool: describe_table
Args: {
"tableName": "ext_{{ENTITY_NAME}}",
"schema": "stg"
}
Falls nicht vorhanden:
External Table
ext_{{ENTITY_NAME}}nicht gefunden.Optionen:
- Zuerst in
sources.ymldefinieren unddbt run-operation stage_external_sourcesausführen- Andere Quelle verwenden (z.B. existierende Tabelle)
Pfad zu Parquet-Dateien: {{PARQUET_PATH}}
Tool: preview_data
Args: {
"tableName": "ext_{{ENTITY_NAME}}",
"schema": "stg",
"limit": 5
}
Zeige Datenvorschau:
Erkannte Spalten und Datentypen:
Spalte Typ Beispielwert id int 42 name varchar "Beispiel GmbH" ...
Welche Spalte(n) bilden den Business Key?
⚠️ Der Business Key muss eindeutig identifizieren und stabil sein.
Kandidaten (typisch für
{{ENTITY_NAME}}):
id- Technischer Schlüssel{{ENTITY_NAME}}_code- Fachlicher Schlüssel- Kombination aus mehreren Spalten?
Tool: create_staging
Args: {
"entityName": "{{ENTITY_NAME}}",
"businessKeyColumns": {{BUSINESS_KEY_COLUMNS}},
"recordSource": "{{RECORD_SOURCE}}"
}
Generierte Spalten:
hk_{{ENTITY_NAME}} - Hash Key aus Business Keyhd_{{ENTITY_NAME}} - Hash Diff aus allen Payload-Spaltendss_load_date - Ladezeitpunktdss_record_source - QuellsystemTool: run_command
Args: {
"command": "dbt run --select stg_{{ENTITY_NAME}}"
}
Prüfe:
{{ENTITY_NAME}}: Name der Entity (z.B. "product"){{BUSINESS_KEY_COLUMNS}}: Array der Business Key Spalten{{RECORD_SOURCE}}: Quellsystem (default: "werkportal"){{PARQUET_PATH}}: Pfad in ADLS (z.B. "werkportal/product/")/create-staging product
Erstellt stg_product.sql mit Hash-Berechnungen für hub_product und sat_product.