import requests
import pyodbc
import schedule
import time
prev_data = None
def job():
global prev_data
conn_str = (
r'DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};'
r'DBQ=path_to_your_database;'
)
conn = pyodbc.connect(conn_str)
cursor = conn.cursor()
# 用你实际的表名和字段名替换 "table_name" 和 "field_names"
cursor.execute("SELECT field_names FROM table_name")
rows = cursor.fetchall()
if prev_data is None:
prev_data = rows
else:
new_data = [row for row in rows if row not in prev_data]
if new_data:
for row in new_data:
# 用你实际的API URL和数据格式替换 "api_url" 和 "data"
response = requests.post('api_url', data = row)
prev_data = rows
conn.close()
schedule.every(10).seconds.do(job)
while True:
schedule.run_pending()
time.sleep(1)