dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
DBT Toate comenzile Snowflake & dbt (Data Stack)

Monitorizarea Prospețimii Datelor: dbt source freshness în Snowflake & dbt (Data Stack)

sources dbt Core 1.8+ / Snowflake Q&A / Distribuie cod

Verificarea automată a întârzierilor de încărcare din sursele externe brute prin loaded_at_field.

Sintaxă 
dbt source freshness

Comanda dbt source freshness verifică dacă datele brute furnizate de instrumentele de ingestie (Fivetran, Airbyte, Kafka) sosesc la timp în Snowflake. Se configurează coloana de timestamp (loaded_at_field) și pragurile de avertizare și eroare.

Exemplu: Configurarea prospețimii sursei în models/staging/sources.yml
version: 2

sources:
  - name: stripe
    database: RAW_DATA
    schema: STRIPE
    freshness:
      warn_after: {count: 12, period: hour}
      error_after: {count: 24, period: hour}
    loaded_at_field: _ingested_at
    tables:
      - name: charges
# Comanda de rulare în terminal sau cron:
dbt source freshness

Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Monitorizarea Prospețimii Datelor: dbt source freshness

Ai o nelămurire despre utilizarea comenzii Monitorizarea Prospețimii Datelor: dbt source freshness sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.