| 实时行情整合输出 (r.py) |
失败 (错误: 2026-06-12 08:31:55,319 - bond_project.task.task_r - INFO - ===== [r.py] 实时整合与输出任务开始 =====
2026-06-12 08:31:55,320 - bond_project.task.task_r - INFO - 获取实时行情数据...
0%| | 0/5 [00:00<?, ?it/s]
20%|██ | 1/5 [00:00<00:01, 3.21it/s]
40%|████ | 2/5 [00:00<00:01, 2.82it/s]
60%|██████ | 3/5 [00:01<00:00, 2.28it/s]
80%|████████ | 4/5 [00:01<00:00, 2.59it/s]
100%|██████████| 5/5 [00:01<00:00, 3.09it/s]
2026-06-12 08:31:57,906 - bond_project.task.task_r - ERROR - 获取实时行情失败: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))
Traceback (most recent call last):
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connectionpool.py", line 787, in urlopen
response = self._make_request(
^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connectionpool.py", line 534, in _make_request
response = conn.getresponse()
^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connection.py", line 565, in getresponse
httplib_response = super().getresponse()
^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 1390, in getresponse
response.begin()
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 325, in begin
version, status, reason = self._read_status()
^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 294, in _read_status
raise RemoteDisconnected("Remote end closed connection without"
http.client.RemoteDisconnected: Remote end closed connection without response
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/adapters.py", line 667, in send
resp = conn.urlopen(
^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connectionpool.py", line 841, in urlopen
retries = retries.increment(
^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/util/retry.py", line 474, in increment
raise reraise(type(error), error, _stacktrace)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/util/util.py", line 38, in reraise
raise value.with_traceback(tb)
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connectionpool.py", line 787, in urlopen
response = self._make_request(
^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connectionpool.py", line 534, in _make_request
response = conn.getresponse()
^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/urllib3/connection.py", line 565, in getresponse
httplib_response = super().getresponse()
^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 1390, in getresponse
response.begin()
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 325, in begin
version, status, reason = self._read_status()
^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/http/client.py", line 294, in _read_status
raise RemoteDisconnected("Remote end closed connection without"
urllib3.exceptions.ProtocolError: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/www/wwwroot/bond/tasks/r.py", line 26, in execute_task_r
comparison_df = ak.bond_cov_comparison()
^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/akshare/bond/bond_zh_cov.py", line 486, in bond_cov_comparison
temp_df = fetch_paginated_data(url, params)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/akshare/utils/func.py", line 32, in fetch_paginated_data
r = requests.get(url, params=params, timeout=timeout)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/api.py", line 73, in get
return request("get", url, params=params, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/api.py", line 59, in request
return session.request(method=method, url=url, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/sessions.py", line 589, in request
resp = self.send(prep, **send_kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/sessions.py", line 703, in send
r = adapter.send(request, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/requests/adapters.py", line 682, in send
raise ConnectionError(err, request=request)
requests.exceptions.ConnectionError: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))
2026-06-12 08:31:57,912 - bond_project.task.task_r - INFO - 加载各频率汇总文件并统一数据类型...
2026-06-12 08:31:57,914 - bond_project.task.task_r - INFO - 成功加载并处理 daily 汇总文件。
2026-06-12 08:31:57,916 - bond_project.task.task_r - INFO - 成功加载并处理 weekly 汇总文件。
2026-06-12 08:31:57,917 - bond_project.task.task_r - INFO - 成功加载并处理 monthly 汇总文件。
2026-06-12 08:31:57,917 - bond_project.task.task_r - INFO - 开始最终数据大合并...
Traceback (most recent call last):
File "/www/wwwroot/bond/tasks/r.py", line 136, in <module>
execute_task_r()
File "/www/wwwroot/bond/tasks/r.py", line 69, in execute_task_r
stock_vol_df = weekly_df[stock_vol_cols].copy().dropna(subset=['stock_code'])
~~~~~~~~~^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/pandas/core/frame.py", line 4113, in __getitem__
indexer = self.columns._get_indexer_strict(key, "columns")[1]
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/pandas/core/indexes/base.py", line 6212, in _get_indexer_strict
self._raise_if_missing(keyarr, indexer, axis_name)
File "/www/server/pyporject_evn/versions/3.11.8/lib/python3.11/site-packages/pandas/core/indexes/base.py", line 6261, in _raise_if_missing
raise KeyError(f"None of [{key}] are in the [{axis_name}]")
KeyError: "None of [Index(['stock_code'], dtype='object')] are in the [columns]") |
2026-06-12 08:31:53 |
2026-06-12 08:31:58 |
|
立即执行
查看日志
|