[FEAT] Add table documentos_hora processorio

pipelines/rj_iplanrio/processorio/schedules.py

@@ -227,6 +227,144 @@
         """,  # noqa
         "dbt_alias": True,
     },
+    "documentos_hora": {
+        "biglake_table": True,
+        "materialize_after_dump": True,
+        "materialization_mode": "prod",
+        "materialize_to_datario": False,
+        "dump_to_gcs": False,
+        "dump_mode": "overwrite",
+        "interval": timedelta(hours=1),
+        "execute_query": """
+            SELECT
+            HORA,
+            QTD_HORA
+            FROM SIGA.VW_MOVIMENTOS_POR_HORA
+        """,  # noqa
+        "dbt_alias": False,
+    },
+    "ex_forma_documento": {
+        "biglake_table": True,
+        "materialize_after_dump": True,
+        "materialization_mode": "prod",
+        "materialize_to_datario": False,
+        "dump_to_gcs": False,
+        "dump_mode": "overwrite",
+        "execute_query": """
+            SELECT
+                ID_FORMA_DOC,
+                DESCR_FORMA_DOC,
+                SIGLA_FORMA_DOC,
+                ID_TIPO_FORMA_DOC
+            FROM SIGA.VW_FORMA_DOCUMENTO
+        """,
+    },
+    "dp_pessoa": {
+        "biglake_table": True,
+        "materialize_after_dump": True,
+        "materialization_mode": "prod",
+        "materialize_to_datario": False,
+        "dump_to_gcs": False,
+        "partition_columns": "DATA_INI_PESSOA",
+        "partition_date_format": "%Y-%m-%d",
+        "lower_bound_date": "current_month",
+        "dump_mode": "append",
+        "execute_query": """
+            SELECT
+                ID_PESSOA,
+                DATA_INI_PESSOA,
+                DATA_FIM_PESSOA,
+                CPF_PESSOA,
+                NOME_PESSOA,
+                DATA_NASC_PESSOA,
+                MATRICULA,
+                ID_LOTACAO,
+                ID_CARGO,
+                ID_FUNCAO_CONFIANCA,
+                SESB_PESSOA,
+                EMAIL_PESSOA,
+                TP_SERVIDOR_PESSOA,
+                SIGLA_PESSOA,
+                SEXO_PESSOA,
+                GRAU_INSTRUCAO_PESSOA,
+                TP_SANGUINEO_PESSOA,
+                NACIONALIDADE_PESSOA,
+                DATA_POSSE_PESSOA,
+                DATA_NOMEACAO_PESSOA,
+                DATA_PUBLICACAO_PESSOA,
+                DATA_INICIO_EXERCICIO_PESSOA,
+                ATO_NOMEACAO_PESSOA,
+                SITUACAO_FUNCIONAL_PESSOA,
+                ID_PROVIMENTO,
+                NATURALIDADE_PESSOA,
+                FG_IMPRIME_END,
+                DSC_PADRAO_REFERENCIA_PESSOA,
+                ID_ORGAO_USU,
+                IDE_PESSOA,
+                ID_PESSOA_INICIAL,
+                ENDERECO_PESSOA,
+                BAIRRO_PESSOA,
+                CIDADE_PESSOA,
+                CEP_PESSOA,
+                TELEFONE_PESSOA,
+                RG_PESSOA,
+                RG_ORGAO_PESSOA,
+                RG_DATA_EXPEDICAO_PESSOA,
+                RG_UF_PESSOA,
+                ID_ESTADO_CIVIL,
+                ID_TP_PESSOA,
+                NOME_EXIBICAO,
+                HIS_IDC_INI,
+                HIS_IDC_FIM,
+                NOME_PESSOA_AI
+            FROM CORPORATIVO.VW_DP_PESSOA
+        """,
+    },
+    "cp_identidade": {
+        "biglake_table": True,
+        "materialize_after_dump": True,
+        "materialization_mode": "prod",
+        "materialize_to_datario": False,
+        "dump_to_gcs": False,
+        "dump_mode": "overwrite",
+        "execute_query": """
+        SELECT
+            ID_IDENTIDADE,
+            ID_TP_IDENTIDADE,
+            ID_PESSOA,
+            DATA_CRIACAO_IDENTIDADE,
+            DATA_EXPIRACAO_IDENTIDADE,
+            DATA_CANCELAMENTO_IDENTIDADE,
+            ID_ORGAO_USU,
+            LOGIN_IDENTIDADE,
+            SENHA_IDENTIDADE,
+            SENHA_IDENTIDADE_CRIPTO,
+            SENHA_IDENTIDADE_CRIPTO_SINC,
+            HIS_ID_INI,
+            HIS_DT_INI,
+            HIS_IDC_INI,
+            HIS_DT_FIM,
+            HIS_IDC_FIM,
+            HIS_ATIVO,
+            PIN_IDENTIDADE
+        FROM CORPORATIVO.CP_IDENTIDADE
+    """,
+    },
+    "ex_tipo_forma_documento": {
+        "biglake_table": True,
+        "materialize_after_dump": True,
+        "materialization_mode": "prod",
+        "materialize_to_datario": False,
+        "dump_to_gcs": False,
+        "dump_mode": "overwrite",
+        "execute_query": """
+        SELECT
+            ID_TIPO_FORMA_DOC,
+            DESC_TIPO_FORMA_DOC,
+            NUMERACAO_UNICA
+        FROM SIGA.EX_TIPO_FORMA_DOCUMENTO
+""",
+    },
 }
 
 processorio_infra_clocks = generate_dump_db_schedules(