Macro-ul run_query() execută instrucțiunea SQL furnizată direct în baza de date Snowflake și returnează rezultatul sub forma unui tabel de date Python (obiect Agate table). Este fundamentul pentru generarea dinamică a codului (cum ar fi aflarea listei de categorii unice pentru a construi dinamic clauze de pivotare).
Exemplu: Preluarea categoriilor unice pentru pivotare automată
{% set query_categorii %}
SELECT DISTINCT categorie FROM {{ ref('stg_produse') }} ORDER BY 1
{% endset %}
{% if execute %}
{% set categorii = run_query(query_categorii).columns[0].values() %}
{% else %}
{% set categorii = [] %}
{% endif %}
SELECT
magazin_id,
{% for cat in categorii %}
SUM(CASE WHEN categorie = '{{ cat }}' THEN valoare ELSE 0 END) AS total_{{ cat }}{% if not loop.last %},{% endif %}
{% endfor %}
FROM {{ ref('stg_vanzari') }}
GROUP BY magazin_id;
Întrebări & Exemple de Cod:
Executarea Interogărilor la Compilare cu run_queryAi o nelămurire despre utilizarea comenzii
Executarea Interogărilor la Compilare cu run_querysau 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.