更改为部署参数

main.py

@@ -113,59 +113,60 @@ class Database():
           table_1 = self.handle_a_table_1(i[j])
           self.insert_into_1(table_1)
           # print(table_1)
-        elif i[j]['no'] == 2:  # not_report
-          table_2 = self.handle_a_table_2(i[j]['tables'])
+        # elif i[j]['no'] == 2:  # not_report
+          # table_2 = self.handle_a_table_2(i[j]['tables'])
           # self.insert_into_2(table_2)
           # print(table_2)
-        elif i[j]['no'] == 3:  # detail
-          table_3 = self.handle_a_table_3(i[j]['tables'])
+        # elif i[j]['no'] == 3:  # detail
+          # table_3 = self.handle_a_table_3(i[j]['tables'])
           # self.insert_into_3(table_3)
           # print(table_3)
-        elif i[j]['no'] == 4:
-          table_4 = self.handle_a_table_4(i[j]['tables'])
+        # elif i[j]['no'] == 4:
+          # table_4 = self.handle_a_table_4(i[j]['tables'])
           # self.insert_into_4(table_4)
           # print(table_4)
-        elif i[j]['no'] == 5:
-          table_5 = self.handle_a_table_5(i[j])
+        # elif i[j]['no'] == 5:
+          # table_5 = self.handle_a_table_5(i[j])
           # if table_5:
           # self.insert_into_5(table_5)
           # print(table_5)
-        elif i[j]['no'] == 6:
-          pass
+        # elif i[j]['no'] == 6:
           # table_6 = self.handle_a_table_6(i[j])
           # if table_6:
           #   self.insert_into_6(table_6)
           # print(table_6)
-        elif i[j]['no'] == 7:
-          table_7 = self.handle_a_table_7(i[j]['tables'])
+        # elif i[j]['no'] == 7:
+          # table_7 = self.handle_a_table_7(i[j]['tables'])
           # print(table_7)
-        elif i[j]['no'] == 8:
-          table_8 = self.handle_a_table_8(i[j])
+        # elif i[j]['no'] == 8:
+          # table_8 = self.handle_a_table_8(i[j])
           # print(table_8)
-        elif i[j]['no'] == 9:
-          table_9 = self.handle_a_table_9(i[j])
+        # elif i[j]['no'] == 9:
+          # table_9 = self.handle_a_table_9(i[j])
           # print(table_9)
-        elif i[j]['no'] == 10:
-          table_10 = self.handle_a_table_10(i[j])
+        # elif i[j]['no'] == 10:
+          # table_10 = self.handle_a_table_10(i[j])
           # print(table_10)
-        elif i[j]['no'] == 11:
-          table_11 = self.handle_a_table_11(i[j])
+        # elif i[j]['no'] == 11:
+          # table_11 = self.handle_a_table_11(i[j])
           # print(table_11)
-        elif i[j]['no'] == 12:
-          table_12 = self.handle_a_table_12(i[j])
+        # elif i[j]['no'] == 12:
+          # table_12 = self.handle_a_table_12(i[j])
           # print(table_12)
-        elif i[j]['no'] == 13:
-          table_13 = self.handle_a_table_13(i[j])
+        # elif i[j]['no'] == 13:
+          # table_13 = self.handle_a_table_13(i[j])
           # print(table_13)
-        elif i[j]['no'] == 14:
-          table_14 = self.handle_a_table_14(i[j])
+        # elif i[j]['no'] == 14:
+          # table_14 = self.handle_a_table_14(i[j])
           # print(table_14)
-        elif i[j]['no'] == 15:
-          table_15 = self.handle_a_table_15(i[j])
+        # elif i[j]['no'] == 15:
+          # table_15 = self.handle_a_table_15(i[j])
           # print(table_15)
-        elif i[j]['no'] == 16:
-          table_16 = self.handle_a_table_16(i[j])
+        # elif i[j]['no'] == 16:
+          # table_16 = self.handle_a_table_16(i[j])
           # print(table_16)
+    with open('ana.log', 'a') as fileReader:
+      fileReader.write('第' + str(self.start) + '条分析完成  年份：' + str(self.year) + ' 国家：' + self.country + ' 类型:' + self.type)
     print('第' + str(self.start) + '条分析完成  年份：' + str(self.year) + ' 国家：' + self.country + ' 类型:' + self.type)
 
   def handle_a_table_1(self, table):

postgre/utils.py

@@ -124,7 +124,8 @@ class psqlUtil(object):
     def open(self):
         # if not hasattr(self, "conn"):
         # 连接到一个给定的数据库
-        self.conn = psycopg2.connect(database="animal_new", user="postgres", password="postgres", host="39.104.109.13", port="5432")
+        self.conn = psycopg2.connect(database="animal_new", user="animal", password="animal@9589", host="172.17.1.61",
+                                 port="5432")
         # 建立游标，用来执行数据库操作
         self.cursor = self.conn.cursor()
         # print("__init__.py", self.conn)