o iw] @sdZddlZddlZddlZddlmZddlmZddlZddl m Z ddl m Z m Z ddl mZddlmZdd lmZdd lmZdd lmZmZmZmZmZd5d dZddZedddd6ddZiad7ddZ ddZ!ddZ"eddddd difd!ee#d"ee$d#ee$d$ee%d%ej&f d&dZ'difd#ee$d$ee%d%ej&fd'd(Z(d%e$fd)d*Z)d difd"ee$d#ee$d$ee%d%ej&fd+d,Z*d7d-d.Z+d/d0Z,d1d2Z-e.d3kre'dd4Z/e0e/dSdS)8uc 所有 A 股的实时行情数据 Created on 2023/12/06 @author: Monday @group : waditu @contact: N)tqdm)Optional) symbol_verify)format_stock_codeverify_stock_or_index)timestemp_to_time)rtq_vars)require_permission)cons)zh_sina_a_stock_payloadzh_sina_a_stock_urlzh_sina_a_stock_count_urlzh_sina_a_stock_headerszh_sina_a_stock_cookies cCs2ddlm}d|d}d|d}t|||S)Nr)randint )randomrstr)nrstartendrD/opt/alphahud/venv/lib/python3.10/site-packages/tushare/stock/rtq.py_random s   rcCstttdS)Ni)rinttimerrrr_get_current_timestamp'srrealtime_quoteu个股实时交易数据) event_name event_detail 688553.SHsinacCs t|}|dkr t|St|S)uX 获取实时交易数据 getting real time quotes data 用于跟踪交易情况（本次执行的结果-上一次执行的数据） Parameters ------ ts_code : string src : sina ，dc return ------- DataFrame 实时交易数据 属性:0：name，股票名字 1：open，今日开盘价 2：pre_close，昨日收盘价 3：price，当前价格 4：high，今日最高价 5：low，今日最低价 6：bid，竞买价，即“买一”报价 7：ask，竞卖价，即“卖一”报价 8：volumn，成交量 maybe you need do volumn/100 9：amount，成交金额（元 CNY） 10：b1_v，委买一（笔数 bid volume） 11：b1_p，委买一（价格 bid price） 12：b2_v，“买二” 13：b2_p，“买二” 14：b3_v，“买三” 15：b3_p，“买三” 16：b4_v，“买四” 17：b4_p，“买四” 18：b5_v，“买五” 19：b5_p，“买五” 20：a1_v，委卖一（笔数 ask volume） 21：a1_p，委卖一（价格 ask price） ... 30：date，日期； 31：time，时间； r#)rget_realtime_quotes_sinaget_realtime_quotes_dc)ts_codesrcsymbolsrrrr+s'688553cCsHg}g}dd|dDD]%}|d}|dt|d<||d|d||dqd}t|tsKt|tsKt|tsKt|t j rW|D]}||d7}qMn|}t |dkre|dd n|}t j t jd t jd t|f}tj|d d ddd}|jd} td} | | } g} g} t| D]"\}}t |dkr| dd|dddD| ||qt | dkrdSt j| t jd}|jddd}| |d<dd|jD}|D] }||dd||<qtj|_|dt |d<|dt!|d<tj"}||}gd}||jt j#dd ||<|$d}|S)!NcSg|]}|qSrr).0jrrr `z,get_realtime_quotes_sina..,.rrhttpsinahqz}Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 Edg/119.0.0.0z hq.sinajs.cnzhttps://finance.sina.com.cn/)z user-agenthostreferer)headersGBKz \="(.*?)\";cSr*rr)r+astrrrrr-|r.!columnss)axiscodecSsg|]}d|vr|qS)_vr)r+clsrrrr-scSs |ddS)Nrxrrrs z*get_realtime_quotes_sina..TS_CODEDATE)OPEN PRE_CLOSEPRICEHIGHLOWBIDASKVOLUMEAMOUNTB1_VB1_PB2_VB2_PB3_VB3_PB4_VB4_PB5_VB5_PA1_VA1_PA2_VA2_PA3_VA3_PA4_VA4_PA5_VA5_Pcoerceerrors)%splituppersina_stock_codeappendlower isinstancelistsettuplepdSerieslenct LIVE_DATA_URLP_TYPEDOMAINSrrequestsgetcontentdecoderecompilefindall enumerate DataFrameLIVE_DATA_COLSdropr=maprtqvapplyformat_sina_stock_codeformat_date_strLIVE_DATA_COLS_REINDEX to_numericfillna)symbolr(symsir> symbols_listr@root_urlresponsetextregdata data_list syms_listindexrowdflstxt new_ordercols_to_convert df_filledrrrr$\sh       "  r$cCs|dt|}|S)Nr0)rk)rEr&rrrrsrcCs |ddS)N-r1)replace)date_strrrrrs r realtime_listuA股所有实时交易数据r'interval page_countproxiesreturncCs0|dkr t||S|dkrt|||St||S)u= 沪深京 A 股 all -实时行情 @param src: 数据源 新浪sina |东方财富 dc @param interval: 分页采集时间间隔（默认3秒翻译一夜） @param page_count: 限制抓取的页数（仅对新浪有效） @param proxies: 设置代理 防止被封禁 @return: 按涨跌幅 倒序排序 ------- DataFrame 实时交易数据 东方财富： 2、代码:TS_CODE 3、名称:NAME 4、最新价:CLOSE 5、涨跌幅:PCT_CHANGE 6、涨跌额:CHANGE 7、成交量:VOLUME 8、成交额:AMOUNT 9、振幅:SWING 10、最高:HIGH 11、最低:LOW 12、今开:OPEN 13、昨收:PRICE 14、量比:VOL_RATIO 15、换手率:TURNOVER_RATE 16、市盈率-动态:PE 17、市净率:PB 18、总市值:TOTAL_MV 19、流通市值:FLOAT_MV 20、涨速:RISE 21、5分钟涨跌:5MIN 22、60日涨跌幅:60DAY 23、年初至今涨跌幅:1YEAR 新浪财经： 1、代码:TS_CODE 2、名称:NAME 3、最新价:CLOSE 4、涨跌额:CHANGE 5、涨跌幅:PCT_CHANGE 6、买入:BUY 7、卖出:SALE 8、昨收:CLOSE 9、今开:OPEN 10、最高:HIGH 11、最低:LOW 12、成交量:VOLUME 13、成交额:AMOUNT 14、时间戳:TIME dcr#)get_stock_all_a_dcget_stock_all_a_sina)r'rrrrrrrs 4   c Csg}tddD]I}d}|dddddddd d d d }|r d |d<tj|||d}|}|ds3nt|dd}gd|_|jdd|gd}|dt |d<tj |ddd|d<tj |ddd|d<tj |ddd|d<tj |ddd|d<tj |ddd|d<tj |ddd|d<tj |ddd|d<tj |d dd|d <tj |d!dd|d!<tj |d"dd|d"<tj |d#dd|d#<tj |d$dd|d$<tj |d%dd|d%<tj |d&dd|d&<tj |d'dd|d'<tj |d(dd|d(<tj |d)dd|d)<tj |d*dd|d*<tj |d+dd|d+<tj |d,dd|d,<gd-|_gd.} || jtj dd|| <| ||rQnqtj |dd/} | d0} | jd1d2d3jdd4} | S)5uN 东方财富网-沪深京 A 股-实时行情 https://quote.eastmoney.com/center/gridlist.html#hs_a_board :return: 实时行情 :rtype: pandas.DataFrame 1、序号:RANK 2、代码:TS_CODE 3、名称:NAME 4、最新价:PRICE 5、涨跌幅:PCT_CHANGE 6、涨跌额:CHANGE 7、成交量:VOLUME 8、成交额:AMOUNT 9、振幅:SWING 10、最高:HIGH 11、最低:LOW 12、今开:OPEN 13、昨收:CLOSE 14、量比:VOL_RATIO 15、换手率:TURNOVER_RATE 16、市盈率-动态:PE 17、市净率:PB 18、总市值:TOTAL_MV 19、流通市值:FLOAT_MV 20、涨速:RISE 21、5分钟涨跌:5MIN 22、60日涨跌幅:60DAY 23、年初至今涨跌幅:1YEAR riz.http://82.push2.eastmoney.com/api/qt/clist/get2001 bd1d9ddb04089700cf9c27f6f74262812f3z1m:0 t:6,m:0 t:80,m:1 t:2,m:1 t:23,m:0 t:81 s:2048znf1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f20,f21,f23,f24,f25,f22,f11,f62,f128,f136,f115,f152 1623833739532) pnpzponputflttinvtfidfsfields_r)paramsrrdiff)r 最新价 涨跌幅 涨跌额 成交量 成交额振幅 换手率市盈率-动态量比 5分钟涨跌代码r名称最高最低今开昨收 总市值 流通市值涨速 市净率60日涨跌幅年初至今涨跌幅rrrrrrrT)inplace)rrrrrrrrrrrrrrrrrrrrrrrrrfrgrrrrrrrrrrrrrrrrrrr)rGNAMErK PCT_CHANGECHANGErPrQSWINGrLrMrICLOSE VOL_RATIO TURNOVER_RATEPEPBTOTAL_MVFLOAT_MVRISE5MIN60DAY1YEAR)rKrrrPrQrrLrMrIrrrrrrrrrrr ignore_indexrrFby ascendingr)rangeryrzjsonrrrr= reset_indexrrrrlconcatr sort_values) rrdfspageurlrr data_jsontemp_dfr result_dfr df_sortedrrrrsz   !  rcCsDtt}tttd|jdd}t|tr|St|dS)u 所有股票的总页数 https://vip.stock.finance.sina.com.cn/mkt/#hs_a :return: 需要采集的股票总页数 :rtype: int z\d+rPr) ryrzr rr}rr~rrn)resrrrr_get_zh_a_page_counts    rc Cs:t}|s t}t}ttd|ddddD](}|d|itj t t t ||d}| }tj|t|gdd}t|q|id d d d d d d d dd dd dd dd dd dd dd dd dd dd dd dd }gd|_|gd}|dt|d<gd|_|jdddjdd }|S)!u 新浪财经-所有 A 股的实时行情数据; 重复运行本函数会被新浪暂时封 IP https://vip.stock.finance.sina.com.cn/mkt/#hs_a :param interval:请求间隔时间 :param page_count:限制抓取页数 :param proxies: 代理ip {} :return: 所有股票的实时行情数据 :rtype: pandas.DataFrame 1、代码:TS_CODE 2、名称:NAME 3、最新价:PRICE 4、涨跌额:CHANGE 5、涨跌幅:PCT_CHANGE 6、买入:BUY 7、卖出:SALE 8、昨收:CLOSE 9、今开:OPEN 10、最高:HIGH 11、最低:LOW 12、成交量:VOLUME 13、成交额:AMOUNT 14、时间戳:TIME rFzPlease wait for a moment)leavedescr)r8cookiesrrTrtradefloat pricechange changepercentbuysell settlementopenhighlowvolumeamountperpbmktcapnmc turnoverratio)rrrrrr买入卖出rrrrrr 时间戳rrrrr)rrrrrrrrrrrrrrr)rGrrKrrBUYSALErrIrLrMrPrQTIMErrr)rrrrr copyrrupdateryrzr rrrrrsleepastyper=rrrr) rrrbig_dfzh_sina_stock_payload_copyrrrrrrrrs|         rc+Cst|dd}d}td|tjtjBd}dddd |d d td }t|s2d ||d<t j |t j t j |d}|d}|sItS|d}|d}|d}|d} |d} |d} t|d} |d} t|d}|d}t|d}|d}t|d}|d}t|d}|d }t|d!}|d"}t|d#}|d$}t|d%}|d&}t|d'}|d(}t|d)}|d*}t|d+} | dd,}!| d,d-}"t|d.}#t|d/}$t|d }%t|d*}&|}'g||| | || |%|&|#|$||||||||| | |||||||||||!|"|'g}(tj|(t jd0})|)d1t|)d1<|)d2t|)d2<|)d3t|)d3<|)d4t|)d4<|)d5t|)d5<|)d6t|)d6<|)d7t|)d7<|)d8t|)d8<|)d9t|)d9<|)d:t|)d:<|)d;t|)d;<|)d<t|)d<<|)d=t|)d=<|)d>t|)d><|)d?t|)d?<|)d@t|)d@<|)dAt|)dA<|)dBt|)dB<t j}*|)|*})|)S)Cz3 https://quote.eastmoney.com/sh601096.html r/rz,https://push2.eastmoney.com/api/qt/stock/getz(\d+)rrrarf58,f734,f107,f57,f43,f59,f169,f301,f60,f170,f152,f177,f111,f46,f44,f45,f47,f260,f48,f261,f279,f277,f278,f288,f19,f17,f531,f15,f13,f11,f20,f18,f16,f14,f12,f39,f37,f35,f33,f31,f40,f38,f36,f34,f32,f211,f212,f213,f214,f215,f210,f209,f208,f207,f206,f161,f49,f171,f50,f86,f84,f85,f168,f108,f116,f167,f164,f162,f163,f92,f71,f117,f292,f51,f52,f191,f192,f262,f294,f295,f748,f747z0. fa5fd1943c7b386f172d6893dbfba10bz |0|0|0|web)rrrsecidrwbp2urz1.r)r8rrrf58f46f44f60f45f43f12f11f14f13f16f15f18f17f20f19f32f31f34f33f36f35f38f37f40f39f86rNf47f48r<rHrOrIrLrMrJrNr]r_rarcrerKrSrUrWrYr[)rrir}searchSMgrouprrryrzr dc_cookies dc_headersrrrrformat_str_to_floatrrrr format_dc_strr)+r(rrrr data_infonamerr pre_closerpriceb5_vb5_pb4_vb4_pb3_vb3_pb2_vb2_pb1_vb1_pa5_va5_pa4_va4_pa3_va3_pa2_va2_pa1_va1_p date_timedatetimesrr bidaskr@rrrrrrr%%s                   *r%cCs|dkr t|dSdS)NrdrrrDrrrrB{srBcCs&z |dkr t|WSdWSYdS)Nr1rrarDrrrrAsrA__main__)r')r)r"r#)r))1__doc__rpandasrrryrtypingrr}tushare.util.format_stock_coderrrtushare.util.form_dater tushare.stockrrtushare.util.verify_tokenr r rutushare.stock.rtq_varsr r r rrrrrrkr$rrrrdictrrrrrr%rBrA__name__rprintrrrrsp          - <  ;  9  V