Cria dicionário RDO

pipelines/migration/br_rj_riodejaneiro_rdo/flows.py

@@ -2,7 +2,7 @@
 """
 Flows for br_rj_riodejaneiro_rdo
 
-DBT 2024-09-06
+DBT: 2025-01-31
 """
 from prefect import Parameter, case
 from prefect.run_configs import KubernetesRun

queries/models/br_rj_riodejaneiro_rdo/dicionario_rdo.sql

@@ -0,0 +1,13 @@
+{{
+    config(
+        materialized="table",
+        alias="dicionario",
+    )
+}}
+select
+    safe_cast(chave as string) as chave,
+    safe_cast(cobertura_temporal as string) as cobertura_temporal,
+    safe_cast(id_tabela as string) as id_tabela,
+    safe_cast(coluna as string) as coluna,
+    safe_cast(valor as string) as valor
+from {{ source("br_rj_riodejaneiro_rdo_staging", "dicionario") }}

queries/models/br_rj_riodejaneiro_rdo/schema.yml

@@ -301,3 +301,16 @@ models:
         quote: true
         description: "{{ doc('datetime_ultima_atualizacao') }}"
     description: Tabela materializada para acesso geral aos dados do RDO STPL
+  - name: dicionario_rdo
+    description: "Dicionário de dados"
+    columns:
+      - name: chave
+        description: "Chave"
+      - name: cobertura_temporal
+        description: "Cobertura temporal"
+      - name: id_tabela
+        description: "Nome da tabela"
+      - name: coluna
+        description: "Nome da coluna"
+      - name: valor
+        description: "Valor"

queries/models/sources.yml

@@ -88,6 +88,7 @@ sources:
       - name: rho_registros_sppo
       - name: rho_registros_stpl
       - name: rdo_registros_stpl
+      - name: dicionario
 
   - name: br_rj_riodejaneiro_rdo
     database: rj-smtr