From d59c3cc2f459097ad85de4e927c67f26440a91d1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=86=E8=A1=8C=E9=B8=9F?= <3785865@qq.com> Date: Wed, 27 Sep 2023 07:13:29 +0000 Subject: [PATCH] =?UTF-8?q?update=20src/zvt/recorders/em/news/em=5Fstock?= =?UTF-8?q?=5Fnews=5Frecorder.py.=20bug=20=E4=BF=AE=E5=A4=8D=E6=89=BE?= =?UTF-8?q?=E4=B8=8D=E5=88=B0=E6=96=B0=E9=97=BB=E7=9A=84=E6=97=B6=E5=80=99?= =?UTF-8?q?=20=E4=BC=9A=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: 陆行鸟 <3785865@qq.com> --- src/zvt/recorders/em/news/em_stock_news_recorder.py | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/src/zvt/recorders/em/news/em_stock_news_recorder.py b/src/zvt/recorders/em/news/em_stock_news_recorder.py index 5202534..dc6b184 100644 --- a/src/zvt/recorders/em/news/em_stock_news_recorder.py +++ b/src/zvt/recorders/em/news/em_stock_news_recorder.py @@ -6,7 +6,6 @@ from zvt.contract.recorder import FixedCycleDataRecorder from zvt.domain import Stock from zvt.domain.misc.stock_news import StockNews from zvt.recorders.em import em_api -from zvt.utils import to_pd_timestamp, count_interval, now_pd_timestamp class EMStockNewsRecorder(FixedCycleDataRecorder): @@ -19,13 +18,7 @@ class EMStockNewsRecorder(FixedCycleDataRecorder): provider = "em" def record(self, entity, start, end, size, timestamps): - if not start or (start <= to_pd_timestamp("2018-01-01")): - start = to_pd_timestamp("2018-01-01") - if count_interval(start, now_pd_timestamp()) <= 30: - ps = 30 - else: - ps = 200 - news = em_api.get_news(entity_id=entity.id, ps=ps, start_timestamp=start) + news = em_api.get_news(entity_id=entity.id) if news: df = pd.DataFrame.from_records(news) self.logger.info(df) @@ -33,8 +26,7 @@ class EMStockNewsRecorder(FixedCycleDataRecorder): if __name__ == "__main__": - # Stock.record_data(provider="em") - r = EMStockNewsRecorder(entity_ids=["stock_sz_000005"]) + r = EMStockNewsRecorder(entity_ids=["stock_sz_000003"]) r.run() # the __all__ is generated __all__ = ["EMStockNewsRecorder"] -- Gitee