=========================================================================
2025-09-16 16:25:33 Tue START TASK.01 future_1d future_receipt
=========================================================================
2025-09-16 16:25:58,270 - future_1d - INFO - future_receipt check=True check_last=7 start...
2025-09-16 16:26:33,235 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-08) done
2025-09-16 16:27:41,449 - future_1d - INFO - save future_receipt 2025-09-08 completed
2025-09-16 16:28:09,018 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-09) done
2025-09-16 16:28:46,726 - future_1d - INFO - save future_receipt 2025-09-09 completed
2025-09-16 16:29:21,721 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-10) done
2025-09-16 16:29:39,075 - future_1d - INFO - save future_receipt 2025-09-10 completed
2025-09-16 16:30:06,165 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-11) done
2025-09-16 16:30:09,469 - future_1d - INFO - save future_receipt 2025-09-11 completed
2025-09-16 16:30:39,476 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-12) done
2025-09-16 16:31:12,681 - future_1d - INFO - save future_receipt 2025-09-12 completed
2025-09-16 16:31:39,935 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-15) done
2025-09-16 16:31:48,701 - future_1d - INFO - save future_receipt 2025-09-15 completed
2025-09-16 16:32:15,023 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-16) done
2025-09-16 16:32:15,251 - future_1d - INFO - save future_receipt 2025-09-16 failed
=========================================================================
2025-09-16 18:25:46 Tue START TASK.01 future_1d future_receipt
=========================================================================
2025-09-16 18:27:46,493 - future_1d - INFO - future_receipt check=True check_last=7 start...
2025-09-16 18:28:12,457 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-08) done
=========================================================================
2025-09-16 19:10:42 Tue START TASK.01 future_1d future_receipt
=========================================================================
2025-09-16 19:11:16,731 - future_1d - INFO - future_receipt check=True check_last=7 start...
2025-09-16 19:11:35,670 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-08) done
2025-09-16 19:11:39,105 - future_1d - INFO - save future_receipt 2025-09-08 completed
2025-09-16 19:12:05,488 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-09) done
2025-09-16 19:12:08,976 - future_1d - INFO - save future_receipt 2025-09-09 completed
2025-09-16 19:12:58,320 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-10) done
2025-09-16 19:13:05,728 - future_1d - INFO - save future_receipt 2025-09-10 completed
2025-09-16 19:13:31,600 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-11) done
2025-09-16 19:13:44,153 - future_1d - INFO - save future_receipt 2025-09-11 completed
2025-09-16 19:14:10,801 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-12) done
2025-09-16 19:14:13,639 - future_1d - INFO - save future_receipt 2025-09-12 completed
2025-09-16 19:14:39,725 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-15) done
2025-09-16 19:14:41,288 - future_1d - INFO - save future_receipt 2025-09-15 completed
2025-09-16 19:15:12,024 - future_1d - INFO - pro.fut_wsr(trade_date=2025-09-16) done
2025-09-16 19:15:15,136 - future_1d - INFO - save future_receipt 2025-09-16 add
2025-09-16 19:15:15,144 - future_1d - INFO - 0 ... 4
date 2025-09-16 ... 2025-09-16
variety AP ... AP
fut_name 苹果 ... 苹果
warehouse 富县子午 ... 洛川延刚
receipt_pre NaN ... NaN
receipt 0.0 ... NaN
receipt_chg 0 ... 0
unit 张 ... 张
comd AP ... AP
created_at 2025-09-16 19:15:12.677632 ... 2025-09-16 19:15:12.677632
updated_at 2025-09-16 19:15:12.678043 ... 2025-09-16 19:15:12.678043
[11 rows x 5 columns]
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 736, in _read_bytes
data = self._rfile.read(num_bytes)
File "/usr/local/lib/python3.10/socket.py", line 705, in readinto
return self._sock.recv_into(b)
ConnectionResetError: [Errno 104] Connection reset by peer
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 1967, in _exec_single_context
self.dialect.do_execute(
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/default.py", line 951, in do_execute
cursor.execute(statement, parameters)
File "/usr/local/lib/python3.10/site-packages/pymysql/cursors.py", line 158, in execute
result = self._query(query)
File "/usr/local/lib/python3.10/site-packages/pymysql/cursors.py", line 325, in _query
conn.query(q)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 549, in query
self._affected_rows = self._read_query_result(unbuffered=unbuffered)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 779, in _read_query_result
result.read()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1164, in read
self._read_result_packet(first_packet)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1240, in _read_result_packet
self._read_rowdata_packet()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1274, in _read_rowdata_packet
packet = self.connection._read_packet()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 715, in _read_packet
recv_data = self._read_bytes(bytes_to_read)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 742, in _read_bytes
raise err.OperationalError(
pymysql.err.OperationalError: (2013, 'Lost connection to MySQL server during query ([Errno 104] Connection reset by peer)')
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/root/project/future_1d/future_receipt.py", line 7, in
client.save_future_receipt(check=True, check_last=7)
File "/root/project/future_1d/future1d_request.py", line 713, in save_future_receipt
df_db = pd.read_sql(f"select * from {tablebase.__tablename__} where date = '{td.strftime('%Y-%m-%d')}'", self.engine)
File "/usr/local/lib/python3.10/site-packages/pandas/io/sql.py", line 736, in read_sql
return pandas_sql.read_query(
File "/usr/local/lib/python3.10/site-packages/pandas/io/sql.py", line 1848, in read_query
result = self.execute(sql, params)
File "/usr/local/lib/python3.10/site-packages/pandas/io/sql.py", line 1671, in execute
return self.con.exec_driver_sql(sql, *args)
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 1779, in exec_driver_sql
ret = self._execute_context(
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 1846, in _execute_context
return self._exec_single_context(
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 1986, in _exec_single_context
self._handle_dbapi_exception(
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 2355, in _handle_dbapi_exception
raise sqlalchemy_exception.with_traceback(exc_info[2]) from e
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/base.py", line 1967, in _exec_single_context
self.dialect.do_execute(
File "/usr/local/lib/python3.10/site-packages/sqlalchemy/engine/default.py", line 951, in do_execute
cursor.execute(statement, parameters)
File "/usr/local/lib/python3.10/site-packages/pymysql/cursors.py", line 158, in execute
result = self._query(query)
File "/usr/local/lib/python3.10/site-packages/pymysql/cursors.py", line 325, in _query
conn.query(q)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 549, in query
self._affected_rows = self._read_query_result(unbuffered=unbuffered)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 779, in _read_query_result
result.read()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1164, in read
self._read_result_packet(first_packet)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1240, in _read_result_packet
self._read_rowdata_packet()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 1274, in _read_rowdata_packet
packet = self.connection._read_packet()
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 715, in _read_packet
recv_data = self._read_bytes(bytes_to_read)
File "/usr/local/lib/python3.10/site-packages/pymysql/connections.py", line 742, in _read_bytes
raise err.OperationalError(
sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (2013, 'Lost connection to MySQL server during query ([Errno 104] Connection reset by peer)')
[SQL: select * from future_receipt where date = '2025-09-08']
(Background on this error at: https://sqlalche.me/e/20/e3q8)