下面代码使用 pytdx 库从通达信获取金融数据。pytdx 是一个用于获取中国股市数据的 Python 库，它通过连接到通达信的服务器来获取股票交易数据。这个示例脚本展示了如何使用 pytdx 库从通达信服务器获取分笔成交数据。
from pytdx.hq import TdxHq_API
# 直接输入 hqget 即可进入交互模式，进入之后，先选择要连接的服务器类型，然后选择要执行的功能，选择菜单里面最后一项退出交互模式。
# https://gitee.com/better319/pytdx/
def get_financial_data(server_ip, server_port, data_function):
try:
api = TdxHq_API()
if api.connect(server_ip, server_port):
data = data_function(api) # 使用传入的函数获取数据
if data is None:
api.disconnect()
return "No data received."
df = api.to_df(data) # 转换为DataFrame
api.disconnect()
return df
else:
return "Connection failed."
except Exception as e:
return f"An exception occurred: {str(e)}"
# 获取通达信的分笔成交数据，参数：服务器IP、服务器端口、函数
df = get_financial_data('119.147.212.81', 7709, lambda api: api.get_transaction_data(0, '000001', 0, 30))
print(df)
- 引入库：
- from pytdx.hq import TdxHq_API
- 这行代码导入了 pytdx 库中的 TdxHq_API 类，用于与通达信的服务器建立连接并获取数据。
- **定义函数 get_financial_data**： 这个函数用于连接通达信服务器，获取金融数据，并将其转换为 pandas.DataFrame 格式。
- 参数： server_ip：服务器的 IP 地址。 server_port：服务器的端口号。 data_function：一个函数，当与服务器连接成功后，此函数被调用以获取数据。
- 异常处理： 使用 try...except 块来处理可能出现的异常，如连接失败或数据获取错误。
- 连接服务器并获取数据： 使用 api.connect() 方法尝试连接到服务器。如果连接成功，调用传入的 data_function 函数来获取数据，然后使用 api.to_df() 方法将数据转换为 pandas.DataFrame。如果数据获取失败或连接失败，函数返回相应的错误信息。
- 使用示例：
- df = get_financial_data('119.147.212.81', 7709, lambda api: api.get_transaction_data(0, '000001', 0, 30))
- 这行代码示例了如何使用 get_financial_data 函数获取股票代码为 '000001' 的前 30 条分笔成交数据。
这段代码的主要作用是方便用户从通达信获取股票市场的实时数据，特别是分笔成交数据。这对于进行股市分析和决策非常有用，因为它提供了市场动态的深入视角。
交互模式该库提供交互模式，直接输入 hqget 即可进入交互模式，进入之后，先选择要连接的服务器类型，然后选择要执行的功能，选择菜单里面最后一项退出交互模式。
