American Tower

A grandes rasgos, este script funciona como un ETL (Extract, Transform, Load) para SIRET:

• Extrae datos desde una base MySQL de SIRET.
• Los guarda temporalmente en archivos JSON.
• Carga esos datos a PostgreSQL en el schema fiber.
• Otorga permisos de lectura sobre las tablas cargadas.
• Registra la ejecución en una tabla de auditoría.

MySQL origen (SIRET)
cnx = create_engine(
"mysql+pymysql://atuser:AmericanTowerSiret@atdb.relevando.com/siret_at_entorno"
)

Extrae tablas desde MySQL
Lee completas tres tablas:
SELECT * FROM Instalaciones;
SELECT * FROM Ordenes_Trabajo;
SELECT * FROM Ordenes_Trabajo_Tareas_Variables;

Las guarda como JSON:
./files/Instalaciones_today.json
./files/Ordenes_Trabajo_today.json
./files/Ordenes_Trabajo_Tareas_Variables_today.json

MySQL SIRET
│
▼
Lee Instalaciones
Lee Ordenes_Trabajo
Lee Ordenes_Trabajo_Tareas_Variables
│
▼
Genera JSON temporales
│
▼
Carga a PostgreSQL (schema fiber)
│
▼
Reemplaza las tablas completas
│
▼
Otorga permisos a om_read
│
▼
Registra ejecución en scripts_ejecutados

Por lo que estuvimos viendo, la query que realiza Netcom es para G25 y G30.

Por este motivo, se le va a solicitar a Netcom que ejecute la query para G20 y G10, pero nos debe diferenciar ahora a que tecnología pertenece cada elemento