From e8a480909df7d7db9c60590aee1e95221ea1b1f4 Mon Sep 17 00:00:00 2001 From: David Itehua Xalamihua Date: Tue, 20 Aug 2024 16:54:54 -0600 Subject: [PATCH] trabajando en la carga de datos al servidor --- help_files/upgrade_coordenadas.py | 65 +++++++++++-------- help_files/upgrade_directorio_centros_sict.py | 62 +++++++++--------- help_files/upgrade_sitios_ai.py | 45 +++++++++++++ 3 files changed, 115 insertions(+), 57 deletions(-) create mode 100644 help_files/upgrade_sitios_ai.py diff --git a/help_files/upgrade_coordenadas.py b/help_files/upgrade_coordenadas.py index 5207c5b..316f8b4 100644 --- a/help_files/upgrade_coordenadas.py +++ b/help_files/upgrade_coordenadas.py @@ -1,39 +1,48 @@ import psycopg2 import json -from lst_servers import * +import os -# Parámetros de conexión a la base de datos +ip_device = os.getenv("ip_device") +db_server = json.loads(os.getenv("dist_servs")) +db_server = db_server[ip_device] +f_path = os.path.join(os.getcwd(), "json_files/coordenas_unicas.json") -json_file_path = ".\json_files\coordenas_unicas.json" -with open(json_file_path, 'r', encoding='utf-8-sig') as f: +# cargar coordenadas a la memoria de la computadora +# json_file_path = ".\json_files\coordenas_unicas.json" +with open(f_path, 'r', encoding='utf-8-sig') as f: json_content = json.load(f) -for ip in l_ips: - conn = psycopg2.connect( - host=ip, - port=5432, - database="coordenadas_mx", - user="postgres", - password="Shala55951254") +# crear la conexión a la base de datos +conn = psycopg2.connect( + host=db_server, + port=5432, + database="coordenadas_mx", + user="postgres", + password="Shala55951254" + ) - cursor = conn.cursor() - cursor.execute("DROP TABLE IF EXISTS coordenadas_mexico;") +cursor = conn.cursor() - create_table_query = """ - CREATE TABLE coordenadas_mexico ( - id SERIAL PRIMARY KEY, - json_data JSONB - );""" +cursor.execute("DROP TABLE IF EXISTS coordenadas_mexico;") - cursor.execute(create_table_query) +# crear la tabla en la base e datos +create_table_query = """ +CREATE TABLE coordenadas_mexico ( +id SERIAL PRIMARY KEY, +json_data JSONB +);""" - # Insertar el contenido JSON en la tabla - insert_query = "INSERT INTO coordenadas_mexico (json_data) VALUES (%s);" - cursor.execute(insert_query, (json.dumps(json_content),)) +cursor.execute(create_table_query) - # guardar cambios - conn.commit() - # Cerrar la conexión - cursor.close() - conn.close() - print(f'Servidor {ip} actualizado en coordenadas de mexico (pais)') +# Insertar el contenido JSON en la tabla +insert_query = "INSERT INTO coordenadas_mexico (json_data) VALUES (%s);" +cursor.execute(insert_query, (json.dumps(json_content),)) + +# guardar cambios +conn.commit() + +# Cerrar la conexión +cursor.close() +conn.close() + +print("se han cargado las coordenadas.") diff --git a/help_files/upgrade_directorio_centros_sict.py b/help_files/upgrade_directorio_centros_sict.py index c64befc..d1ca722 100644 --- a/help_files/upgrade_directorio_centros_sict.py +++ b/help_files/upgrade_directorio_centros_sict.py @@ -1,39 +1,43 @@ import psycopg2 import json -from lst_servers import * -# Parámetros de conexión a la base de datos +import os -json_file_path = ".\json_files\DirectorioCSICT.json" -with open(json_file_path, 'r', encoding='utf-8-sig') as f: +ip_device = os.getenv("ip_device") +db_server = json.loads(os.getenv("dist_servs")) +db_server = db_server[ip_device] + +# Parámetros de conexión a la base de datos +file_path = os.path.join(os.getcwd(), "json_files/DirectorioCSICT.json") + +# json_file_path = ".\json_files\DirectorioCSICT.json" +with open(file_path, 'r', encoding='utf-8-sig') as f: json_content = json.load(f) +conn = psycopg2.connect( + host=db_server, + port=5432, + database="aldeas_inteligentes", + user="postgres", + password="Shala55951254" +) -for ip in l_ips: - conn = psycopg2.connect( - host=ip, - port=5432, - database="aldeas_inteligentes", - user="postgres", - password="Shala55951254") +cursor = conn.cursor() - cursor = conn.cursor() - cursor.execute("DROP TABLE IF EXISTS dir_csict;") +create_table_query = """ +CREATE TABLE dir_csict ( +id SERIAL PRIMARY KEY, +json_data JSONB +);""" - create_table_query = """ - CREATE TABLE dir_csict ( - id SERIAL PRIMARY KEY, - json_data JSONB - );""" +cursor.execute(create_table_query) - cursor.execute(create_table_query) +# Insertar el contenido JSON en la tabla +insert_query = "INSERT INTO dir_csict (json_data) VALUES (%s);" +cursor.execute(insert_query, (json.dumps(json_content),)) - # Insertar el contenido JSON en la tabla - insert_query = "INSERT INTO dir_csict (json_data) VALUES (%s);" - cursor.execute(insert_query, (json.dumps(json_content),)) - - # guardar cambios - conn.commit() - # Cerrar la conexión - cursor.close() - conn.close() - print(f'Servidor {ip} actualizado en directorio centros sict') +# guardar cambios +conn.commit() +# Cerrar la conexión +cursor.close() +conn.close() +print(f'Servidor actualizado en directorio centros sict') diff --git a/help_files/upgrade_sitios_ai.py b/help_files/upgrade_sitios_ai.py new file mode 100644 index 0000000..6e134b2 --- /dev/null +++ b/help_files/upgrade_sitios_ai.py @@ -0,0 +1,45 @@ +import psycopg2 +import json +import os + +ip_device = os.getenv("ip_device") +db_server = json.loads(os.getenv("dist_servs")) +db_server = db_server[ip_device] + +# Parámetros de conexión a la base de datos +f_path = os.path.join(os.getcwd(), "json_files/sitios.json") + +# json_file_path = ".\json_files\sitios.json" +with open(f_path, 'r', encoding='utf-8-sig') as f: + json_content = json.load(f) + +conn = psycopg2.connect( + host=db_server, + port=5432, + database="aldeas_inteligentes", + user="postgres", + password="Shala55951254" +) + +cursor = conn.cursor() +cursor.execute("DROP TABLE IF EXISTS sitios;") + +create_table_query = """ +CREATE TABLE sitios ( +id SERIAL PRIMARY KEY, +json_data JSONB +);""" + +cursor.execute(create_table_query) + +# Insertar el contenido JSON en la tabla +insert_query = "INSERT INTO sitios (json_data) VALUES (%s);" +cursor.execute(insert_query, (json.dumps(json_content),)) + +# guardar cambios +conn.commit() + +# Cerrar la conexión +cursor.close() +conn.close() +print('Servidor actualizado en sitios') \ No newline at end of file