update:ループ処理の実装&テーブルカラムの修正

Author: dero1to

docker/mysql/sql/001-create-tables.sql

@@ -17,6 +17,7 @@ create table IF not exists train_log(
     odpt_to_station VARCHAR(255) ,
     odpt_from_station VARCHAR(255) ,
     odpt_rail_direction VARCHAR(255) ,
+    odpt_car_composition VARCHAR(255),
     odpt_destination_station VARCHAR(255) ,
     created_at Datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
     updated_at Datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,

train-api.py

@@ -1,6 +1,8 @@
 import requests
 import os
 import json
+import time
+import datetime
 from sqlalchemy import create_engine, text
 
 def mysql_connector():
@@ -16,14 +18,20 @@ def api_request():
 def mysql_insert(engine, res):
   for value in res:
     if value['odpt:railway'] == "odpt.Railway:JR-East.ChuoRapid":
-      q = text("INSERT INFO train_log (train_id, odpt_type, dc_date, dct_valid, odpt_delay, odpt_railway, odpt_operator, odpt_train_number, odpt_train_type, odpt_toStation, odpt_from_station, odpt_rail_direction, odpt_car_composition, odpt_destination_station) VALUES (%s, %s, %s, %s, %d, %s, %s, %s, %s, %s, %s, %s, %d, %s);" % (value['@id'], value['@type'], value['dc:date'], value['dct:valid'], value['odpt:delay'], value['odpt:railway'], value['odpt:operator'], value['odpt_train_number'], value['odpt_train_type'], value['odpt_toStation'], value['odpt_from_station'], value['odpt_rail_direction'], value['odpt_car_composition'], value['odpt_destination_station']))
+      # print(value)
+      q = text("INSERT INTO train_log(train_id, odpt_type, dc_date, dct_valid, odpt_delay, odpt_railway, odpt_operator, odpt_train_number, odpt_train_type, odpt_to_station, odpt_from_station, odpt_rail_direction, odpt_car_composition, odpt_destination_station) VALUES ('%s', '%s', '%s', '%s', %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, '%s');" % (value['@id'], value['@type'], value['dc:date'], value['dct:valid'], value['odpt:delay'], value['odpt:railway'], value['odpt:operator'], value['odpt:trainNumber'], value['odpt:trainType'], value['odpt:toStation'], value['odpt:fromStation'], value['odpt:railDirection'], value['odpt:carComposition'], "a"))
       rs = engine.execute(q)
-      print(rs)
+  print("Insert Success!\n")
 
 def main():
   engine = mysql_connector()
-  res = api_request()
-  mysql_insert(engine, res)
+  value = 0
+  while True:
+    print("開始時間:"+str(datetime.datetime.now())+"__"+str(value+1)+"回目")
+    res = api_request()
+    mysql_insert(engine, res)
+    value += 1
+    time.sleep(10)
 
 if __name__ == '__main__':
   main()