金融科技【免费下载链接】tqsdk-python天勤量化开发包, 期货量化, 实时行情/历史数据/实盘交易项目地址https://gitcode.com/gh_mirrors/tq/tqsdk-python点击查看免费下载TqSdk 天勤量化开发包tqsdk-python不仅是一套面向策略用户的量化 SDK其内部架构也遵循着一套明确的开发原则与规范。本文基于官方开发文档 doc/dev_general.rst系统梳理 TqSdk 的三大设计原则不预设用户策略模型、保持用户代码简单、行为可验证并结合仓库源码剖析这些原则在TqApi、TqChan、Diff 协议、日志与单元测试框架中的具体落地方式。读完本文你将理解 TqSdk 为什么是同步写法 异步内核的形态、为什么切换实盘/模拟/回测只需单点修改以及如何利用日志复现线上问题并参与源码开发。一、TqSdk 的三大设计原则doc/dev_general.rst将 TqSdk 的开发纲领概括为三条原则。它们共同决定了仓库中每一行代码的形态是理解全部源码的前提。1. 不预设用户策略模型量化交易是一个高度竞争与创新的领域成功的用户总是在不断构思和尝试全新的理念与模型。在这方面用户比库的开发者知道得更多、走得也更快。因此 TqSdk 在设计时尽力避免对用户的策略模型结构做任何限定专注于提供通用性的资源和能力。文档中列出的三项设计决策印证了这一原则不提供策略类模板只以示例程序方式展示各类策略应用仓库中不存在任何强制继承的Strategy基类而是通过 tqsdk/demo/example/双均线、网格、海龟、统计套利、价差交易等数十个示例与 tqsdk/demo/tutorial/t10 行情、backtest 回测、replay 复盘等教程演示各类策略写法。一个策略程序中可以任意获取数据和发出指令获取行情、K 线、下单、撤单等操作全部是TqApi上的平级方法没有数据阶段/决策阶段/执行阶段的强约束流程。允许用户在一个程序中使用任意多个TqApi实例同时操作多组行情与账户如股票 期货并行或借助 TqMultiAccount 在单个 api 内组合多个账户。从源码看TqApi的构造参数刻意设计成组合式而非模板式账户实盘TqAccount、模拟TqSim、快期TqKq、众期TqZq、CTP 直连TqCtp等、鉴权TqAuth、回测TqBacktest都是独立对象见 tqsdk/api.py。用户按需传入即可库本身不做策略框架假设。2. 保持用户代码简单TqSdk 的一个核心设计目标是让用户的代码与需求方案保持一致顺序相同、篇幅相当。也就是说策略逻辑是什么样就写成什么样而不是被 SDK 的复杂度污染。对应四项设计决策设计决策含义源码佐证不使用多线程避免用户处理线程同步问题整个 tqsdk 源码目录中不存在import threading并发全部基于asyncio单线程协程模型不使用回调模型避免用户维护状态机状态变量用户代码以api.wait_update()驱动的主动查询写法为主数据更新由 is_changing 判断而非注册回调提供专门的调仓工具把目标持仓→拆单→下单的机械工作交给库TargetPosTask、TargetPosScheduler、InsertOrderTask等封装在 tqsdk/lib 中实盘/模拟/回测单点切换运行模式切换只需改一处代码见下文模式切换小节典型的用户代码只有十来行却完成了订阅行情→计算信号→目标持仓调整→循环等待的完整闭环例如官方教程 tqsdk/demo/tutorial/backtest.pyfrom datetime import date from tqsdk import TqApi, TqAuth, TqBacktest, TargetPosTask api TqApi(backtestTqBacktest(start_dtdate(2018, 5, 1), end_dtdate(2018, 10, 1)), authTqAuth(快期账户, 账户密码)) klines api.get_kline_serial(DCE.m1901, 5 * 60, data_length15) target_pos TargetPosTask(api, DCE.m1901) while True: api.wait_update() if api.is_changing(klines): ma sum(klines.close.iloc[-15:]) / 15 if klines.close.iloc[-1] ma: target_pos.set_target_volume(5) # 目标多头 5 手 elif klines.close.iloc[-1] ma: target_pos.set_target_volume(0) # 目标空仓这段代码没有多线程、没有回调、没有状态机与价格高于 MA 就多、低于就平的需求描述几乎一一对应——这正是保持用户代码简单原则的直接体现。3. 行为可验证作为库质量管控的关键措施TqSdk 要求运行时可以记录完整的输入信息确保发生问题时可以稳定重现问题和定位原因。对应三项设计决策以数据流衔接库中的各组件组件之间不直接互相调用而是通过通道传递数据包使数据走向可追踪、可插拔详见第二节。TqSdk 的日志文件完整记录收到的全部数据包日志默认写入~/.tqsdk/logs/目录见 tqsdk/log.py。专门构建了一个单元测试框架可以直接用日志作为测试用例输入开发文档中对应的 doc/dev/unittest.rst 记录了这一设计把真实运行日志作为回放输入可以精确复现历史数据到达顺序从而稳定重现 BUG。二、设计原则的落地TqChan 数据流与 asyncio 内核保持用户代码简单与行为可验证在架构层面的统一解是内部用 asyncio 协程 数据流管道外部向用户暴露同步风格 API。1. TqChan本质是一个 asyncio.Queue配套开发文档 doc/dev/framework.rst 明确指出TqSdk 中以数据流的方式连接各组件。TqChan本质是一个 asyncio.Queue被用作两个组件间的单向数据流管道一个组件向 TqChan 中放入数据包另一个组件从 TqChan 中依次取出数据包。源码中TqChan直接继承自asyncio.Queuetqsdk/channel.py并支持last_only只保留最后一个对象等参数。作为开发调试的辅助可以设置TqChan._level 10让内部 chan 传输的数据也打印到日志中方便追踪数据包流转from tqsdk import TqChan TqChan._level 102. 实盘数据流上行与下行doc/dev/framework.rst给出了实盘模式下组件与通道的全景行情网关与交易网关各有一个 websocket 客户端TqConnect中间组件TqAccount等与TqApi之间通过 6 条通道衔接md_send_chan/md_recv_chan行情方向的上行/下行管道td_send_chan/td_recv_chan交易方向的上行/下行管道api_send_chan/api_recv_chan与TqApi主循环衔接的管道数据包上行流程以报单为例用户程序调用TqApi.insert_order等需要发出数据包的功能函数该函数生成一个数据包放入api_send_chanTqAccount从api_send_chan取出数据包根据aid字段决定放入td_send_chan连接到交易网关的 websocket client 从td_send_chan取出数据包通过网络发出。数据包下行流程以接收行情为例连接到行情网关的 websocket client 从网络收到一个数据包放入md_recv_chanTqAccount从md_recv_chan取出数据包放入api_recv_chanTqApi从api_recv_chan取出数据包将其中携带的行情数据合并到内存存储区中。每个环节的日志中都会带chan_id/conn_id等结构化字段见 tqsdk/channel.py配合日志可以完整还原某一数据包从网络到用户可见对象的全路径——这正是行为可验证的架构保障。3. 模式切换单点修改如何做到基于组件可插拔的数据流结构通过简单更换部分组件即可实现不同工作模式模拟交易用TqSim替换TqAccount本地完成撮合成交tqsdk/tradeable/sim/回测在TqSim之上再插入TqBacktest组件由它从回测行情服务拉取历史数据并按start_dt/end_dt推进时间tqsdk/backtest/backtest.pybacktest_send_chan/backtest_recv_chan取代实盘通道。因此用户代码中唯一的差异就是TqApi构造参数。对比两个官方教程即可验证单点修改实时行情tqsdk/demo/tutorial/t10.pyfrom tqsdk import TqApi, TqAuth api TqApi(authTqAuth(快期账户, 账户密码)) # 默认使用内部模拟账户 TqSim quote api.get_quote(SHFE.ni2206) print(quote.datetime, quote.last_price) api.close()回测tqsdk/demo/tutorial/backtest.pyapi TqApi(backtestTqBacktest(start_dtdate(2018, 5, 1), end_dtdate(2018, 10, 1)), authTqAuth(快期账户, 账户密码))实盘则把第一个参数换成TqAccount(期货公司, 资金账号, 密码)即可。策略主体代码完全不变。值得一提的是回测模式下wait_update每次最多推进一个行情时间回测结束时会抛出BacktestFinished异常tqsdk/backtest/backtest.py这是策略循环退出回测的标准途径开发者编写/调试回测代码时应予以处理。三、用户视角的同步写法wait_update 与 is_changing不使用多线程、不使用回调模型落到实处是TqApi提供的一对核心原语wait_update(deadline)这是 TqApi 主循环里最重要的函数tqsdk/api.py。调用时当前线程会阻塞直到收到业务数据更新或到达deadline。每次调用都会顺带完成实际发出待发送的网络请求订阅、下单、撤单、推进后台任务如TargetPosTask调仓、尝试接收并合并新的业务数据包。不填deadline时无限等待填写后超时返回False。is_changing(obj, key)在wait_update返回后判断本次更新是否包含特定对象或字段tqsdk/api.py。key可以是单个字段名或字段名列表不指定则任意字段更新都视为变化。is_changing内部通过比对待处理 diff 列表self._diffs/self._sync_diffs与对象路径实现这也是它需要与wait_update配对使用的原因。while True: api.wait_update() if api.is_changing(quote, last_price): print(quote.last_price)这一同步风格循环 内部异步调度的写法让不了解 asyncio 的用户也能写出正确的策略而开发者阅读源码时则需要理解背后的协程模型见第四节。四、参与 TqSdk 开发所需的知识与技能doc/dev_general.rst明确列出了理解与改进 TqSdk 代码前需要掌握的四块知识点。下面结合源码逐项说明其在仓库中的落点。1. 金融相关业务知识TqSdk 是用于金融交易领域的专用软件包文档假定用户和开发者已具备相应基础知识合约、订单类型、保证金、涨跌停、换月等并在文档中不再详加解释。策略业务字段如pos_long、pos_short、float_profit定义于 tqsdk/objs.py交易账户类期货、期权、股票、资管柜台实现于 tqsdk/tradeable/均以金融业务概念为语义基础。2. Python asyncioTqSdk 的代码大量依赖 python asyncio 机制这是内部并发模型的基石TqApi维护自己的事件循环wait_update在内部驱动该循环处理待发/待收数据包TqChan本质是asyncio.Queue通道两端的生产者/消费者都是协程websocket 通信基于异步库见 tqsdk/connect.py 中的import asyncio、import websockets用户还可以通过api.create_task(coro)把自己的异步任务纳入 TqApi 循环统一调度tqsdk/api.py。文档特别提醒对使用者TqSdk 尽量隐藏了 asyncio 概念允许用户在不了解 asyncio 的情况下实现绝大多数业务需求但对开发者若不了解 asyncio理解 TqSdk 内部实现会非常困难。与之配套的异步开发细节见 doc/dev/async_tool.rst。3. Diff 协议TqSdk 并不是一个 all-in-one 的包它的能力有赖于一系列后台服务行情网关、交易中继网关的支持。Diff 协议是 TqSdk 与后台服务间通讯的主要协议也是以数据流衔接组件的直接体现网关统一以 Diff 协议对下方提供服务见 README.md 的系统架构说明客户端侧TqApi按照 Diff 协议推荐的实践使用单一变量_data存储全部业务数据行情 交易结构分层为quotes/klines/ticks/trade等详见 doc/dev/framework.rst核心合并函数是 tqsdk/diff.py 中的_merge_diff将收到的 diff 包递归合并进内存数据同时同步发送更新通知保证业务数据更新与通知是原子操作reduce_diff参数还支撑了is_changing需要真正有变化的字段这一场景。理解 Diff 协议才能掌握 TqSdk 内部实现的精髓——包括增量更新、断线重连后如何重建完整数据截面TqReconnectHandler的职责之一见 tqsdk/connect.py。4. Pandas / NumPyPandas/NumPy 是非常优秀的 Python 数值计算库TqSdk 利用它们完成K 线序列数据的存储和操作api.get_kline_serial()返回的是 pandas DataFrame 形态的序列对象见 tqsdk/api.pyklines.close.iloc[-1]、sum(klines.close.iloc[-15:]) / 15这类向量化计算直接可用内部还针对不同 pandas 版本兼容了底层BlockPlacement/FloatBlock等内部结构tqsdk/api.py说明 TqSdk 对 pandas 的适配是深度级别的技术指标与计算函数位于 tqsdk/ta.py、tqsdk/tafunc.py示例见 tqsdk/demo/ta.py。五、行为可验证的工程配套日志与调试行为可验证不是口号而是有具体的工程配套。理解这些无论排查问题还是参与开发都事半功倍。1. 日志文件的位置、命名与清理源码 tqsdk/log.py 定义了默认日志行为日志目录~/.tqsdk/logs首次使用时自动创建文件名格式%Y%m%d%H%M%S%f-{进程号}.log即每个进程启动即生成独立日志文件日志内容完整记录收到的全部数据包配合TqChan._level 10可进一步记录内部 chan 流转的数据清理策略_clear_logs默认保留最近 30 天可用环境变量TQ_SAVE_LOG_DAYS调整并且保证磁盘剩余空间大于 3G且最近 3 个自然日至少一个最近交易日的日志永不清除。当出现持仓、成交、行情对不上等问题时把对应时间段的日志连同复现脚本一起提供给开发者即可用日志回放定位问题——这正是单元测试框架以日志作为测试用例输入的前提。2. 单元测试与开发文档导航参与开发的完整入口是 doc/dev/index.rst其中按general原则与规范即本文、framework整体结构、async_tool异步工具、gui、backtest、unittest单元测试等主题组织。其中 doc/dev/framework.rst 提供了文件结构、数据流图与内存数据结构的详细说明建议与本文配套阅读。六、代码风格与开发约定TqSdk 的代码风格遵循PEP8 规范见 doc/dev_general.rst。仓库中可观察到的配套约定还包括模块划分清晰api.pyTqApi 主接口、objs.py业务数据结构、diff.pyDiff 协议实现、channel.py数据流管道、connect.py网络连接与重连、log.py日志各司其职与 doc/dev/framework.rst 的文件结构说明一致工程配置齐全setup.py/setup.cfg/requirements.txt与MANIFEST.in位于仓库根目录供安装与打包使用安装方式TqSdk 支持 Python 3.9 及以上版本可通过pip install tqsdk安装见 README.md。结语TqSdk 的三条设计原则——不预设用户策略模型、保持用户代码简单、行为可验证——并不是抽象的口号而是贯穿了TqApi的同步风格 API、TqChan的数据流管道、Diff 协议的增量数据管理、~/.tqsdk/logs的完整日志以及日志即测试用例的测试思路。理解这些原则你就掌握了阅读与改进 TqSdk 源码的钥匙从 tqsdk/api.py 的主循环进入沿TqChan顺藤摸瓜用 Diff 协议解释数据更新用日志验证每一个数据包的来龙去脉即可快速融入这个成熟量化 SDK 的开发工作。赞分享金融科技【免费下载链接】tqsdk-python天勤量化开发包, 期货量化, 实时行情/历史数据/实盘交易项目地址https://gitcode.com/gh_mirrors/tq/tqsdk-python点击查看免费下载相关推荐Laravel Mail CSS Inliner 项目教程Laravel Mail CSS Inliner 项目教程 1. 项目的目录结构及介绍 laravel mail css inliner/ ├── config金融科技终极指南Meteor DDP协议如何实现实时数据同步的技术内幕终极指南Meteor DDP协议如何实现实时数据同步的技术内幕 Meteor是一个强大的JavaScript应用平台其核心优势之一就是通过DDP分布式数据后端前端开发工具移动开发ts-extras API完全参考从基础到高级的函数使用手册ts extras API完全参考从基础到高级的函数使用手册 TypeScript开发者必备的终极工具包 ts extras 是一个为TypeScrip开发工具上一篇sway-farm前端自动化测试Jest与React Testing Library实践下一篇GitBucket前端框架选型解决方案指南方法论与工具选型创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
金融科技【免费下载链接】tqsdk-python天勤量化开发包, 期货量化, 实时行情/历史数据/实盘交易项目地址https://gitcode.com/gh_mirrors/tq/tqsdk-python点击查看免费下载TqSdk 天勤量化开发包tqsdk-python不仅是一套面向策略用户的量化 SDK其内部架构也遵循着一套明确的开发原则与规范。本文基于官方开发文档 doc/dev_general.rst系统梳理 TqSdk 的三大设计原则不预设用户策略模型、保持用户代码简单、行为可验证并结合仓库源码剖析这些原则在TqApi、TqChan、Diff 协议、日志与单元测试框架中的具体落地方式。读完本文你将理解 TqSdk 为什么是同步写法 异步内核的形态、为什么切换实盘/模拟/回测只需单点修改以及如何利用日志复现线上问题并参与源码开发。一、TqSdk 的三大设计原则doc/dev_general.rst将 TqSdk 的开发纲领概括为三条原则。它们共同决定了仓库中每一行代码的形态是理解全部源码的前提。1. 不预设用户策略模型量化交易是一个高度竞争与创新的领域成功的用户总是在不断构思和尝试全新的理念与模型。在这方面用户比库的开发者知道得更多、走得也更快。因此 TqSdk 在设计时尽力避免对用户的策略模型结构做任何限定专注于提供通用性的资源和能力。文档中列出的三项设计决策印证了这一原则不提供策略类模板只以示例程序方式展示各类策略应用仓库中不存在任何强制继承的Strategy基类而是通过 tqsdk/demo/example/双均线、网格、海龟、统计套利、价差交易等数十个示例与 tqsdk/demo/tutorial/t10 行情、backtest 回测、replay 复盘等教程演示各类策略写法。一个策略程序中可以任意获取数据和发出指令获取行情、K 线、下单、撤单等操作全部是TqApi上的平级方法没有数据阶段/决策阶段/执行阶段的强约束流程。允许用户在一个程序中使用任意多个TqApi实例同时操作多组行情与账户如股票 期货并行或借助 TqMultiAccount 在单个 api 内组合多个账户。从源码看TqApi的构造参数刻意设计成组合式而非模板式账户实盘TqAccount、模拟TqSim、快期TqKq、众期TqZq、CTP 直连TqCtp等、鉴权TqAuth、回测TqBacktest都是独立对象见 tqsdk/api.py。用户按需传入即可库本身不做策略框架假设。2. 保持用户代码简单TqSdk 的一个核心设计目标是让用户的代码与需求方案保持一致顺序相同、篇幅相当。也就是说策略逻辑是什么样就写成什么样而不是被 SDK 的复杂度污染。对应四项设计决策设计决策含义源码佐证不使用多线程避免用户处理线程同步问题整个 tqsdk 源码目录中不存在import threading并发全部基于asyncio单线程协程模型不使用回调模型避免用户维护状态机状态变量用户代码以api.wait_update()驱动的主动查询写法为主数据更新由 is_changing 判断而非注册回调提供专门的调仓工具把目标持仓→拆单→下单的机械工作交给库TargetPosTask、TargetPosScheduler、InsertOrderTask等封装在 tqsdk/lib 中实盘/模拟/回测单点切换运行模式切换只需改一处代码见下文模式切换小节典型的用户代码只有十来行却完成了订阅行情→计算信号→目标持仓调整→循环等待的完整闭环例如官方教程 tqsdk/demo/tutorial/backtest.pyfrom datetime import date from tqsdk import TqApi, TqAuth, TqBacktest, TargetPosTask api TqApi(backtestTqBacktest(start_dtdate(2018, 5, 1), end_dtdate(2018, 10, 1)), authTqAuth(快期账户, 账户密码)) klines api.get_kline_serial(DCE.m1901, 5 * 60, data_length15) target_pos TargetPosTask(api, DCE.m1901) while True: api.wait_update() if api.is_changing(klines): ma sum(klines.close.iloc[-15:]) / 15 if klines.close.iloc[-1] ma: target_pos.set_target_volume(5) # 目标多头 5 手 elif klines.close.iloc[-1] ma: target_pos.set_target_volume(0) # 目标空仓这段代码没有多线程、没有回调、没有状态机与价格高于 MA 就多、低于就平的需求描述几乎一一对应——这正是保持用户代码简单原则的直接体现。3. 行为可验证作为库质量管控的关键措施TqSdk 要求运行时可以记录完整的输入信息确保发生问题时可以稳定重现问题和定位原因。对应三项设计决策以数据流衔接库中的各组件组件之间不直接互相调用而是通过通道传递数据包使数据走向可追踪、可插拔详见第二节。TqSdk 的日志文件完整记录收到的全部数据包日志默认写入~/.tqsdk/logs/目录见 tqsdk/log.py。专门构建了一个单元测试框架可以直接用日志作为测试用例输入开发文档中对应的 doc/dev/unittest.rst 记录了这一设计把真实运行日志作为回放输入可以精确复现历史数据到达顺序从而稳定重现 BUG。二、设计原则的落地TqChan 数据流与 asyncio 内核保持用户代码简单与行为可验证在架构层面的统一解是内部用 asyncio 协程 数据流管道外部向用户暴露同步风格 API。1. TqChan本质是一个 asyncio.Queue配套开发文档 doc/dev/framework.rst 明确指出TqSdk 中以数据流的方式连接各组件。TqChan本质是一个 asyncio.Queue被用作两个组件间的单向数据流管道一个组件向 TqChan 中放入数据包另一个组件从 TqChan 中依次取出数据包。源码中TqChan直接继承自asyncio.Queuetqsdk/channel.py并支持last_only只保留最后一个对象等参数。作为开发调试的辅助可以设置TqChan._level 10让内部 chan 传输的数据也打印到日志中方便追踪数据包流转from tqsdk import TqChan TqChan._level 102. 实盘数据流上行与下行doc/dev/framework.rst给出了实盘模式下组件与通道的全景行情网关与交易网关各有一个 websocket 客户端TqConnect中间组件TqAccount等与TqApi之间通过 6 条通道衔接md_send_chan/md_recv_chan行情方向的上行/下行管道td_send_chan/td_recv_chan交易方向的上行/下行管道api_send_chan/api_recv_chan与TqApi主循环衔接的管道数据包上行流程以报单为例用户程序调用TqApi.insert_order等需要发出数据包的功能函数该函数生成一个数据包放入api_send_chanTqAccount从api_send_chan取出数据包根据aid字段决定放入td_send_chan连接到交易网关的 websocket client 从td_send_chan取出数据包通过网络发出。数据包下行流程以接收行情为例连接到行情网关的 websocket client 从网络收到一个数据包放入md_recv_chanTqAccount从md_recv_chan取出数据包放入api_recv_chanTqApi从api_recv_chan取出数据包将其中携带的行情数据合并到内存存储区中。每个环节的日志中都会带chan_id/conn_id等结构化字段见 tqsdk/channel.py配合日志可以完整还原某一数据包从网络到用户可见对象的全路径——这正是行为可验证的架构保障。3. 模式切换单点修改如何做到基于组件可插拔的数据流结构通过简单更换部分组件即可实现不同工作模式模拟交易用TqSim替换TqAccount本地完成撮合成交tqsdk/tradeable/sim/回测在TqSim之上再插入TqBacktest组件由它从回测行情服务拉取历史数据并按start_dt/end_dt推进时间tqsdk/backtest/backtest.pybacktest_send_chan/backtest_recv_chan取代实盘通道。因此用户代码中唯一的差异就是TqApi构造参数。对比两个官方教程即可验证单点修改实时行情tqsdk/demo/tutorial/t10.pyfrom tqsdk import TqApi, TqAuth api TqApi(authTqAuth(快期账户, 账户密码)) # 默认使用内部模拟账户 TqSim quote api.get_quote(SHFE.ni2206) print(quote.datetime, quote.last_price) api.close()回测tqsdk/demo/tutorial/backtest.pyapi TqApi(backtestTqBacktest(start_dtdate(2018, 5, 1), end_dtdate(2018, 10, 1)), authTqAuth(快期账户, 账户密码))实盘则把第一个参数换成TqAccount(期货公司, 资金账号, 密码)即可。策略主体代码完全不变。值得一提的是回测模式下wait_update每次最多推进一个行情时间回测结束时会抛出BacktestFinished异常tqsdk/backtest/backtest.py这是策略循环退出回测的标准途径开发者编写/调试回测代码时应予以处理。三、用户视角的同步写法wait_update 与 is_changing不使用多线程、不使用回调模型落到实处是TqApi提供的一对核心原语wait_update(deadline)这是 TqApi 主循环里最重要的函数tqsdk/api.py。调用时当前线程会阻塞直到收到业务数据更新或到达deadline。每次调用都会顺带完成实际发出待发送的网络请求订阅、下单、撤单、推进后台任务如TargetPosTask调仓、尝试接收并合并新的业务数据包。不填deadline时无限等待填写后超时返回False。is_changing(obj, key)在wait_update返回后判断本次更新是否包含特定对象或字段tqsdk/api.py。key可以是单个字段名或字段名列表不指定则任意字段更新都视为变化。is_changing内部通过比对待处理 diff 列表self._diffs/self._sync_diffs与对象路径实现这也是它需要与wait_update配对使用的原因。while True: api.wait_update() if api.is_changing(quote, last_price): print(quote.last_price)这一同步风格循环 内部异步调度的写法让不了解 asyncio 的用户也能写出正确的策略而开发者阅读源码时则需要理解背后的协程模型见第四节。四、参与 TqSdk 开发所需的知识与技能doc/dev_general.rst明确列出了理解与改进 TqSdk 代码前需要掌握的四块知识点。下面结合源码逐项说明其在仓库中的落点。1. 金融相关业务知识TqSdk 是用于金融交易领域的专用软件包文档假定用户和开发者已具备相应基础知识合约、订单类型、保证金、涨跌停、换月等并在文档中不再详加解释。策略业务字段如pos_long、pos_short、float_profit定义于 tqsdk/objs.py交易账户类期货、期权、股票、资管柜台实现于 tqsdk/tradeable/均以金融业务概念为语义基础。2. Python asyncioTqSdk 的代码大量依赖 python asyncio 机制这是内部并发模型的基石TqApi维护自己的事件循环wait_update在内部驱动该循环处理待发/待收数据包TqChan本质是asyncio.Queue通道两端的生产者/消费者都是协程websocket 通信基于异步库见 tqsdk/connect.py 中的import asyncio、import websockets用户还可以通过api.create_task(coro)把自己的异步任务纳入 TqApi 循环统一调度tqsdk/api.py。文档特别提醒对使用者TqSdk 尽量隐藏了 asyncio 概念允许用户在不了解 asyncio 的情况下实现绝大多数业务需求但对开发者若不了解 asyncio理解 TqSdk 内部实现会非常困难。与之配套的异步开发细节见 doc/dev/async_tool.rst。3. Diff 协议TqSdk 并不是一个 all-in-one 的包它的能力有赖于一系列后台服务行情网关、交易中继网关的支持。Diff 协议是 TqSdk 与后台服务间通讯的主要协议也是以数据流衔接组件的直接体现网关统一以 Diff 协议对下方提供服务见 README.md 的系统架构说明客户端侧TqApi按照 Diff 协议推荐的实践使用单一变量_data存储全部业务数据行情 交易结构分层为quotes/klines/ticks/trade等详见 doc/dev/framework.rst核心合并函数是 tqsdk/diff.py 中的_merge_diff将收到的 diff 包递归合并进内存数据同时同步发送更新通知保证业务数据更新与通知是原子操作reduce_diff参数还支撑了is_changing需要真正有变化的字段这一场景。理解 Diff 协议才能掌握 TqSdk 内部实现的精髓——包括增量更新、断线重连后如何重建完整数据截面TqReconnectHandler的职责之一见 tqsdk/connect.py。4. Pandas / NumPyPandas/NumPy 是非常优秀的 Python 数值计算库TqSdk 利用它们完成K 线序列数据的存储和操作api.get_kline_serial()返回的是 pandas DataFrame 形态的序列对象见 tqsdk/api.pyklines.close.iloc[-1]、sum(klines.close.iloc[-15:]) / 15这类向量化计算直接可用内部还针对不同 pandas 版本兼容了底层BlockPlacement/FloatBlock等内部结构tqsdk/api.py说明 TqSdk 对 pandas 的适配是深度级别的技术指标与计算函数位于 tqsdk/ta.py、tqsdk/tafunc.py示例见 tqsdk/demo/ta.py。五、行为可验证的工程配套日志与调试行为可验证不是口号而是有具体的工程配套。理解这些无论排查问题还是参与开发都事半功倍。1. 日志文件的位置、命名与清理源码 tqsdk/log.py 定义了默认日志行为日志目录~/.tqsdk/logs首次使用时自动创建文件名格式%Y%m%d%H%M%S%f-{进程号}.log即每个进程启动即生成独立日志文件日志内容完整记录收到的全部数据包配合TqChan._level 10可进一步记录内部 chan 流转的数据清理策略_clear_logs默认保留最近 30 天可用环境变量TQ_SAVE_LOG_DAYS调整并且保证磁盘剩余空间大于 3G且最近 3 个自然日至少一个最近交易日的日志永不清除。当出现持仓、成交、行情对不上等问题时把对应时间段的日志连同复现脚本一起提供给开发者即可用日志回放定位问题——这正是单元测试框架以日志作为测试用例输入的前提。2. 单元测试与开发文档导航参与开发的完整入口是 doc/dev/index.rst其中按general原则与规范即本文、framework整体结构、async_tool异步工具、gui、backtest、unittest单元测试等主题组织。其中 doc/dev/framework.rst 提供了文件结构、数据流图与内存数据结构的详细说明建议与本文配套阅读。六、代码风格与开发约定TqSdk 的代码风格遵循PEP8 规范见 doc/dev_general.rst。仓库中可观察到的配套约定还包括模块划分清晰api.pyTqApi 主接口、objs.py业务数据结构、diff.pyDiff 协议实现、channel.py数据流管道、connect.py网络连接与重连、log.py日志各司其职与 doc/dev/framework.rst 的文件结构说明一致工程配置齐全setup.py/setup.cfg/requirements.txt与MANIFEST.in位于仓库根目录供安装与打包使用安装方式TqSdk 支持 Python 3.9 及以上版本可通过pip install tqsdk安装见 README.md。结语TqSdk 的三条设计原则——不预设用户策略模型、保持用户代码简单、行为可验证——并不是抽象的口号而是贯穿了TqApi的同步风格 API、TqChan的数据流管道、Diff 协议的增量数据管理、~/.tqsdk/logs的完整日志以及日志即测试用例的测试思路。理解这些原则你就掌握了阅读与改进 TqSdk 源码的钥匙从 tqsdk/api.py 的主循环进入沿TqChan顺藤摸瓜用 Diff 协议解释数据更新用日志验证每一个数据包的来龙去脉即可快速融入这个成熟量化 SDK 的开发工作。赞分享金融科技【免费下载链接】tqsdk-python天勤量化开发包, 期货量化, 实时行情/历史数据/实盘交易项目地址https://gitcode.com/gh_mirrors/tq/tqsdk-python点击查看免费下载相关推荐Laravel Mail CSS Inliner 项目教程Laravel Mail CSS Inliner 项目教程 1. 项目的目录结构及介绍 laravel mail css inliner/ ├── config金融科技终极指南Meteor DDP协议如何实现实时数据同步的技术内幕终极指南Meteor DDP协议如何实现实时数据同步的技术内幕 Meteor是一个强大的JavaScript应用平台其核心优势之一就是通过DDP分布式数据后端前端开发工具移动开发ts-extras API完全参考从基础到高级的函数使用手册ts extras API完全参考从基础到高级的函数使用手册 TypeScript开发者必备的终极工具包 ts extras 是一个为TypeScrip开发工具上一篇sway-farm前端自动化测试Jest与React Testing Library实践下一篇GitBucket前端框架选型解决方案指南方法论与工具选型创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
