Jelajahi Sumber

调整治理

baoyubo 9 bulan lalu
induk
melakukan
42b44d7e9e
1 mengubah file dengan 14 tambahan dan 11 penghapusan
  1. 14 11
      DataGovernance.py

+ 14 - 11
DataGovernance.py

@@ -29,11 +29,11 @@ def put_area(table : str,longitude='longitude',latitude='latitude'):
     conn=None
     cur = None
     try:
-        conn = pymysql.connect(host=settings.mysql_dwd_config['host'],
-                               user=settings.mysql_dwd_config['username'],
-                               password=settings.mysql_dwd_config['password'],
-                               database=settings.mysql_dwd_config['database'],
-                               port=settings.mysql_dwd_config['port'],
+        conn = pymysql.connect(host=settings.MYSQL_SERVER,
+                               user=settings.MYSQL_USER,
+                               password=settings.MYSQL_PASSWORD,
+                               database=settings.MYSQL_DB_NAME,
+                               port=settings.MYSQL_PORT,
                                charset='utf8mb4')
         cur = conn.cursor()
         sql = f'select id,{longitude},{latitude} from {table}'
@@ -58,11 +58,11 @@ def put_uuid(table,column):
     conn = None
     cur = None
     try:
-        conn = pymysql.connect(host=settings.mysql_dwd_config['host'],
-                               user=settings.mysql_dwd_config['username'],
-                               password=settings.mysql_dwd_config['password'],
-                               database=settings.mysql_dwd_config['database'],
-                               port=settings.mysql_dwd_config['port'],
+        conn = pymysql.connect(host=settings.MYSQL_SERVER,
+                               user=settings.MYSQL_USER,
+                               password=settings.MYSQL_PASSWORD,
+                               database=settings.MYSQL_DB_NAME,
+                               port=settings.MYSQL_PORT,
                                charset='utf8mb4')
         cur = conn.cursor()
         sql = f'select distinct {column} from {table}'
@@ -83,9 +83,12 @@ def put_uuid(table,column):
             conn.close()
 
 
-put_uuid('rescue_materia','management_unit')
+#put_uuid('rescue_materia','management_unit')
 
 #put_area('emergency_expert')
 # put_area('mid_waterlogged_roads','lng','lat')
 # put_area('mid_school')
 # put_area('mid_hospital')
+# put_area('tower_list')
+put_area('govdata_real_time_address')
+