main_sync.py•1.53 kB
"""
本示例演示了如何使用同步风格来调用异步函数编写代码
但还是有局限性，可以在Python REPL环境中一行行输入使用，但无法在Windows下的Jupyter Notebook中使用
使用方法有3种，选一种即可
1. 直接`python main_sync.py`运行本文件
2. 在控制台中输入`python`,提示`>>>`,然后输入代码
3. 在VSCode中选中一行，让后右键`Run Python` > `Run Selection/Line in Native Python REPL`
- 可以使用Shift+Enter来运行选中代码。但要在插件中禁用`Jupyter`，因为`Run in Interactive Window`下的功能快捷键冲突
"""
# %%
import revolving_asyncio # pip install revolving_asyncio
# revolving_asyncio.apply()
# %%
from mcp_query_table import query, QueryType, Site, BrowserManager
bm = BrowserManager(endpoint="http://127.0.0.1:9333", executable_path=r'C:\Program Files (x86)\Microsoft\Edge\Application\msedge.exe', devtools=False)
query = revolving_asyncio.to_sync(query)
get_page = revolving_asyncio.to_sync(bm.get_page)
release_page = revolving_asyncio.to_sync(bm.release_page)
# %%
page1 = get_page()
page2 = get_page()
df = query(page2, '收盘价>50元的港股', query_type=QueryType.HKStock, max_page=3, site=Site.THS)
print(df.to_markdown())
# %%
df = query(page1, '年初至今收益率前50', query_type=QueryType.Fund, max_page=3, site=Site.TDX)
print(df.to_csv())
# %%
df = query(page2, '收盘价>50元', query_type=QueryType.HKStock, max_page=3, site=Site.EastMoney)
release_page(page1)
release_page(page2)
print(df)