fintie.stock.live_quotes

本模块负责获取股票的历史交易行情信息。

获取通道包括：

数据加载

trades:

import json
from pathlib import Path

import pandas as pd

with Path('SZ002353-trade-20181019201938.json').open(encoding="utf-8") as f:
    quotes = json.load(f)

df = pd.DataFrame(data=quotes["items"])
df.timestamp = pd.to_datetime(df.timestamp, unit="ms")
df.set_index("timestamp", inplace=True)

TODO:

  • add default http headers

    headers = {“X-Forwarded-For”: ipAddress}

async fintie.stock.live_quotes.async_get_trade_info(session, symbol, data_path=None, return_df=True)[源代码]

获取最近的交易记录

参数

  • session – aiohttp.ClientSession 对象，同步接口不需要传

  • symbol – 股票代码

  • data_path – 数据保存路径

  • return_df – 是否返回 pandas.DataFrame 对象，False 返回原始数据

返回

行情原始数据或带有行情数据的 pandas.DataFrame 对象，见 return_df 参数

async fintie.stock.live_quotes.async_get_pankou(session, symbol, data_path=None)[源代码]

获取最新的盘口数据 :param session: aiohttp.ClientSession 对象，同步接口不需要传 :param symbol: 股票代码 :param data_path: 数据保存路径

返回

盘口数据 dict

async fintie.stock.live_quotes.async_get_live_info(session, symbol, data_path=None)[源代码]

获取最新的基本信息，包括最新价格市值等

参数

  • session – aiohttp.ClientSession 对象，同步接口不需要传

  • symbol – 股票代码

  • data_path – 数据保存路径

返回

基本信息数据 dict

fintie.stock.live_quotes.get_trade_info(*args, **kwargs)[源代码]

获取最近的交易记录

参数

  • session – aiohttp.ClientSession 对象，同步接口不需要传

  • symbol – 股票代码

  • data_path – 数据保存路径

  • return_df – 是否返回 pandas.DataFrame 对象，False 返回原始数据

返回

行情原始数据或带有行情数据的 pandas.DataFrame 对象，见 return_df 参数

fintie.stock.live_quotes.get_pankou(*args, **kwargs)[源代码]

获取最新的盘口数据 :param session: aiohttp.ClientSession 对象，同步接口不需要传 :param symbol: 股票代码 :param data_path: 数据保存路径

返回

盘口数据 dict

fintie.stock.live_quotes.get_live_info(*args, **kwargs)[源代码]

获取最新的基本信息，包括最新价格市值等

参数

  • session – aiohttp.ClientSession 对象，同步接口不需要传

  • symbol – 股票代码

  • data_path – 数据保存路径

返回

基本信息数据 dict