富途 OpenAPI Python SDK 提供了连接港股、美股市场的自动化交易方案。本文涵盖环境搭建（安装 futu-api）、行情获取（OpenQuoteContext）、交易执行（OpenHKTradeContext）等核心模块。内容包括实时数据订阅、持仓查询、股票筛选及 K 线数据处理示例。此外，还介绍了连接管理、错误处理及回调机制等高级技巧，帮助开发者构建稳定的量化交易系统。
在开始之前，你需要确保已经安装了富途 OpenD 网关客户端。这是连接富途服务器的桥梁，所有 API 调用都通过这个网关进行中转。
首先通过 pip 安装最新版本的 SDK：
pip install futu-api
当前版本为 9.02.5208，支持 Python 2.7 和 3.x 版本。安装完成后，依赖包包括 pandas、protobuf、PyCryptodome 等，确保你的交易系统稳定运行。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
使用加密算法（如AES、TripleDES、Rabbit或RC4）加密和解密文本明文。 在线工具，加密/解密文本在线工具，online
解析常见 curl 参数并生成 fetch、axios、PHP curl 或 Python requests 示例代码。 在线工具，curl 转代码在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online
将 Markdown（GFM）转为 HTML 片段，浏览器内 marked 解析；与 HTML 转 Markdown 互为补充。 在线工具，Markdown 转 HTML在线工具，online
将 HTML 片段转为 GitHub Flavored Markdown，支持标题、列表、链接、代码块与表格等；浏览器内处理，可链接预填。 在线工具，HTML 转 Markdown在线工具，online
让我们从一个简单的示例开始，体验 SDK 的强大功能：
import futu as ft
quote_ctx = ft.OpenQuoteContext(host="127.0.0.1", port=11111)
market = ft.Market.HK
stock_codes = ['HK.00700', 'HK.00001']
result = quote_ctx.get_market_snapshot(stock_codes)
if result[0] == ft.RET_OK:
print("成功获取市场数据")
for stock in result[1]:
print(f"股票代码：{stock.stock_code}")
print(f"当前价格：{stock.cur_price}")
else:
print(f"获取数据失败：{result[1]}")
quote_ctx.close()
行情模块是量化策略的眼睛，为你提供准确的市场数据：
quote_ctx.subscribe(stock_codes, [ft.SubType.QUOTE, ft.SubType.TICKER])
quote_data = quote_ctx.get_stock_quote('HK.00700')
print(f"腾讯控股实时报价：{quote_data}")
交易模块负责策略的执行，确保你的交易意图准确传达：
trade_ctx = ft.OpenHKTradeContext(host="127.0.0.1", port=11111)
unlock_result = trade_ctx.unlock_trade(password='你的交易密码')
positions = trade_ctx.position_list_query()
print(f"当前持仓：{positions}")
基于财务指标和价格条件，自动筛选符合要求的投资标的：
def advanced_stock_filter(api_ip, api_port):
quote_ctx = ft.OpenQuoteContext(host=api_ip, port=api_port)
price_filter = ft.SimpleFilter()
price_filter.stock_field = ft.StockField.CUR_PRICE
price_filter.filter_min = 10
price_filter.filter_max = 200
ret, data = quote_ctx.get_stock_filter(market=ft.Market.HK, filter_list=[price_filter])
if ret == ft.RET_OK:
print(f"找到 {len(data[2])} 只符合条件的股票")
quote_ctx.close()
构建实时监控系统，及时捕捉市场变化：
class RealTimeQuoteHandler(ft.StockQuoteHandlerBase):
def on_recv_rsp(self, rsp_pb):
ret_code, content = super().on_recv_rsp(rsp_pb)
if ret_code == ft.RET_OK:
stock_code = content['code']
price = content['cur_price']
print(f"实时价格更新：{stock_code} - {price}")
稳定的连接是交易系统的基础，以下技巧确保你的系统始终在线：
quote_ctx.reconnect_interval = 5
利用 pandas 进行高效数据处理：
import pandas as pd
kline_data = quote_ctx.get_cur_kline('HK.00700', num=100, ktype=ft.KLType.K_DAY)
if kline_data[0] == ft.RET_OK:
df = pd.DataFrame(kline_data[1])
print(df.head())
当遇到连接问题时，按照以下顺序检查：
确保你的代码能够优雅处理各种异常情况：
try:
result = quote_ctx.get_market_snapshot(['HK.00700'])
except Exception as e:
print(f"数据获取异常：{e}")
创建个性化的数据处理逻辑：
class CustomTickerHandler(ft.TickerHandlerBase):
def on_recv_rsp(self, rsp_pb):
process_tick_data(rsp_pb)
return ft.RET_OK, "处理成功"
对于高频交易场景，这些优化将显著提升系统性能：