下面代码使用 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 即可进入交互模式，进入之后，先选择要连接的服务器类型，然后选择要执行的功能，选择菜单里面最后一项退出交互模式。