本文整理汇总了Python中tushare.stock.cons._write_console函数的典型用法代码示例。如果您正苦于以下问题：Python _write_console函数的具体用法？Python _write_console怎么用？Python _write_console使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了_write_console函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: _get_report_data
def _get_report_data(year, quarter, pageNo, dataArr):
url = ct.REPORT_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'],
year, quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]//span/a/text()')[0]
name = trs.xpath('td[2]/span/a/text()')[0]
eps = trs.xpath('td[3]/text()')[0] #每股收益(元)
eps_yoy = trs.xpath('td[4]/text()')[0] #每股收益同比(%)
bvps = trs.xpath('td[5]/text()')[0] #每股净资产(元)
bvps = '0' if bvps == '--' else bvps
roe = trs.xpath('td[6]/text()')[0] #净资产收益率(%)
roe = '0' if roe == '--' else roe
epcf = trs.xpath('td[7]/text()')[0] #每股现金流量(元)
epcf = '0' if epcf == '--' else epcf
net_profits = trs.xpath('td[8]/text()')[0] #净利润(万元)
profits_yoy = trs.xpath('td[9]/text()')[0] #净利润同比(%)
distrib = trs.xpath('td[10]/text()')[0] #分配方案
report_date = trs.xpath('td[11]/text()')[0] #发布日期
dataArr.append([code, name, eps, eps_yoy, bvps, roe,
epcf, net_profits, profits_yoy, distrib,
report_date])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_report_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:33，代码来源:fundamental.py
示例2: _get_report_data
def _get_report_data(year, quarter, pageNo, dataArr, orderby):
ct._write_console()
try:
request = Request(ct.REPORT_URL % (ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'],
year, quarter, pageNo, ct.PAGE_NUM[1], orderby))
# 默认排序抓取的信息有重复和遗漏,增加排序功能参数orderby
text = urlopen(request, timeout=10).read()
text = text.decode('GBK')
text = text.replace('--', '')
html = lxml.html.parse(StringIO(text))
res = html.xpath("//table[@class=\"list_table\"]/tr")
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>' % sarr
df = pd.read_html(sarr)[0]
df = df.drop(11, axis=1)
df.columns = ct.REPORT_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick')
if len(nextPage) > 0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_report_data(year, quarter, pageNo, dataArr,orderby)
else:
return dataArr
except Exception as e:
print(e)
开发者ID:afayge，项目名称:tushare，代码行数:29，代码来源:fundamental.py
示例3: _get_debtpaying_data
def _get_debtpaying_data(year, quarter, pageNo, dataArr):
ct._write_console()
try:
request = Request(ct.DEBTPAYING_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'],
ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1]))
text = urlopen(request, timeout=ct.HTTP_TIMEOUT).read()
text = text.decode('GBK')
html = lxml.html.parse(StringIO(text))
res = html.xpath("//table[@class=\"list_table\"]/tr")
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>'%sarr
df = pd.read_html(sarr)[0]
df.columns = ct.DEBTPAYING_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick')
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_debtpaying_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except Exception as e:
print(e)
开发者ID:kiinoo，项目名称:tushare，代码行数:27，代码来源:fundamental.py
示例4: _dist_cotent
def _dist_cotent(year, pageNo, retry_count, pause):
for _ in range(retry_count):
time.sleep(pause)
try:
if pageNo > 0:
ct._write_console()
html = lxml.html.parse(
rv.DP_163_URL % (ct.P_TYPE["http"], ct.DOMAINS["163"], ct.PAGES["163dp"], year, pageNo)
)
res = html.xpath('//div[@class="fn_rp_list"]/table')
if ct.PY3:
sarr = [etree.tostring(node).decode("utf-8") for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = "".join(sarr)
df = pd.read_html(sarr, skiprows=[0])[0]
df = df.drop(df.columns[0], axis=1)
df.columns = rv.DP_163_COLS
df["divi"] = df["plan"].map(_fun_divi)
df["shares"] = df["plan"].map(_fun_into)
df = df.drop("plan", axis=1)
df["code"] = df["code"].astype(object)
df["code"] = df["code"].map(lambda x: str(x).zfill(6))
if pageNo == 0:
page = html.xpath('//div[@class="mod_pages"]/a')
asr = page[len(page) - 2]
pages = asr.xpath("text()")
except _network_error_classes:
pass
else:
if pageNo == 0:
return df, pages[0]
else:
return df
raise IOError(ct.NETWORK_URL_ERROR_MSG)
开发者ID:xyicheng，项目名称:tushare，代码行数:35，代码来源:reference.py
示例5: _get_forecast_data
def _get_forecast_data(year, quarter, pageNo, dataArr):
url = ct.FORECAST_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]//span/a/text()')[0]
name = trs.xpath('td[2]/span/a/text()')[0]
type = trs.xpath('td[3]/a/text()')
type = type[0] if len(type)>0 else trs.xpath('td[3]/text()')[0]
report_date = trs.xpath('td[4]/text()')[0]
pre_eps = trs.xpath('td[7]/text()')[0]
pre_eps = '0' if pre_eps == '--' else pre_eps
range = trs.xpath('td[8]/text()')[0]
dataArr.append([code,name,type,report_date,pre_eps,range])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+',nextPage[0])[0]
return _get_forecast_data(year,quarter,pageNo,dataArr)
else:
return dataArr
except:
pass
开发者ID:renzhexigua，项目名称:tushare，代码行数:25，代码来源:reference.py
示例6: _inst_tops
def _inst_tops(last=5, pageNo=1, retry_count=3, pause=0.001, dataArr=pd.DataFrame()):
ct._write_console()
for _ in range(retry_count):
time.sleep(pause)
try:
request = Request(
rv.LHB_SINA_URL % (ct.P_TYPE["http"], ct.DOMAINS["vsf"], rv.LHB_KINDS[2], ct.PAGES["fd"], last, pageNo)
)
text = urlopen(request, timeout=10).read()
text = text.decode("GBK")
html = lxml.html.parse(StringIO(text))
res = html.xpath('//table[@id="dataTable"]/tr')
if ct.PY3:
sarr = [etree.tostring(node).decode("utf-8") for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = "".join(sarr)
sarr = "<table>%s</table>" % sarr
df = pd.read_html(sarr)[0]
df = df.drop([2, 3], axis=1)
df.columns = rv.LHB_JGZZ_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class="pages"]/a[last()]/@onclick')
if len(nextPage) > 0:
pageNo = re.findall(r"\d+", nextPage[0])[0]
return _inst_tops(last, pageNo, retry_count, pause, dataArr)
else:
return dataArr
except Exception as e:
print(e)
开发者ID:foolish3，项目名称:tushare，代码行数:30，代码来源:billboard.py
示例7: _dist_cotent
def _dist_cotent(year, pageNo, retry_count, pause):
url = rv.DP_163_URL%(ct.P_TYPE['http'], ct.DOMAINS['163'],
ct.PAGES['163dp'], year, pageNo)
for _ in range(retry_count):
time.sleep(pause)
try:
if pageNo > 0:
ct._write_console()
html = lxml.html.parse(url)
res = html.xpath('//div[@class=\"fn_rp_list\"]/table')
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
df = pd.read_html(sarr, skiprows=[0])[0]
df = df.drop(df.columns[0], axis=1)
df.columns = rv.DP_163_COLS
df['divi'] = df['plan'].map(_fun_divi)
df['shares'] = df['plan'].map(_fun_into)
df = df.drop('plan', axis=1)
df['code'] = df['code'].astype(object)
df['code'] = df['code'].map(lambda x : str(x).zfill(6))
if pageNo == 0:
page = html.xpath('//div[@class=\"mod_pages\"]/a')
asr = page[len(page)-2]
pages = asr.xpath('text()')
except _network_error_classes:
pass
else:
if pageNo == 0:
return df, pages[0]
else:
return df
raise IOError(ct.NETWORK_URL_ERROR_MSG)
开发者ID:renzhexigua，项目名称:tushare，代码行数:35，代码来源:reference.py
示例8: _get_detail
def _get_detail(tag, retry_count=3, pause=10):
dfc = pd.DataFrame()
p = 0
num_limit = 100
while(True):
p = p+1
for _ in range(retry_count):
time.sleep(pause)
try:
ct._write_console()
request = Request(ct.SINA_DATA_DETAIL_URL%(ct.P_TYPE['http'],
ct.DOMAINS['vsf'], ct.PAGES['jv'],
p,tag))
text = urlopen(request, timeout=10).read()
text = text.decode('gbk')
except _network_error_classes:
pass
else:
break
reg = re.compile(r'\,(.*?)\:')
text = reg.sub(r',"\1":', text)
text = text.replace('"{symbol', '{"symbol')
text = text.replace('{symbol', '{"symbol"')
jstr = json.dumps(text)
js = json.loads(jstr)
df = pd.DataFrame(pd.read_json(js, dtype={'code':object}), columns=ct.THE_FIELDS)
df = df[ct.FOR_CLASSIFY_B_COLS]
dfc = pd.concat([dfc, df])
if df.shape[0] < num_limit:
return dfc
开发者ID:lotusk，项目名称:tushare，代码行数:30，代码来源:classifying.py
示例9: _today_ticks
def _today_ticks(symbol, tdate, pageNo, retry_count, pause):
ct._write_console()
for _ in range(retry_count):
time.sleep(pause)
try:
html = lxml.html.parse(ct.TODAY_TICKS_URL % (ct.P_TYPE['http'],
ct.DOMAINS['vsf'], ct.PAGES['t_ticks'],
symbol, tdate, pageNo
))
res = html.xpath('//table[@id=\"datatbl\"]/tbody/tr')
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>'%sarr
sarr = sarr.replace('--', '0')
#df = pd.DataFrame(columns=ct.TODAY_TICK_COLUMNS)
df = pd.read_html(StringIO(sarr), infer_types=False)[0]
df.columns = list(ct.TODAY_TICK_COLUMNS)
df['Pchange'] = df['Pchange'].map(lambda x : x.replace('%',''))
df.insert(0,'Date',tdate)
#cols = ct.TODAY_TICK_COLUMNS.insert(0,'Date')
df = df[cols]
except _network_error_classes:
pass
else:
return df
raise IOError("获取失败，请检查网络" )
开发者ID:renzhexigua，项目名称:tushare，代码行数:29，代码来源:trading.py
示例10: _get_forecast_data
def _get_forecast_data(year, quarter, pageNo, dataArr):
ct._write_console()
try:
html = lxml.html.parse(
ct.FORECAST_URL
% (ct.P_TYPE["http"], ct.DOMAINS["vsf"], ct.PAGES["fd"], year, quarter, pageNo, ct.PAGE_NUM[1])
)
res = html.xpath('//table[@class="list_table"]/tr')
if ct.PY3:
sarr = [etree.tostring(node).decode("utf-8") for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = "".join(sarr)
sarr = sarr.replace("--", "0")
sarr = "<table>%s</table>" % sarr
df = pd.read_html(sarr)[0]
df = df.drop([4, 5, 8], axis=1)
df.columns = ct.FORECAST_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class="pages"]/a[last()]/@onclick')
if len(nextPage) > 0:
pageNo = re.findall(r"\d+", nextPage[0])[0]
return _get_forecast_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:xyicheng，项目名称:tushare，代码行数:27，代码来源:reference.py
示例11: _sh_mx
def _sh_mx(data, date="", start="", end="", symbol="", pageNo="", beginPage="", endPage="", retry_count=3, pause=0.001):
for _ in range(retry_count):
time.sleep(pause)
ct._write_console()
try:
tail = "&pageHelp.pageNo=%s&pageHelp.beginPage=%s&pageHelp.endPage=%s" % (pageNo, beginPage, endPage)
if pageNo == "":
pageNo = 6
tail = ""
else:
pageNo += 5
beginPage = pageNo
endPage = pageNo + 4
ref = rv.MAR_SH_HZ_REF_URL % (ct.P_TYPE["http"], ct.DOMAINS["sse"])
clt = Client(
rv.MAR_SH_MX_URL
% (
ct.P_TYPE["http"],
ct.DOMAINS["sseq"],
ct.PAGES["qmd"],
_random(5),
date,
symbol,
start,
end,
tail,
_random(),
),
ref=ref,
cookie=rv.MAR_SH_COOKIESTR,
)
lines = clt.gvalue()
lines = lines.decode("utf-8") if ct.PY3 else lines
lines = lines[19:-1]
lines = json.loads(lines)
pagecount = int(lines["pageHelp"].get("pageCount"))
datapage = int(pagecount / 5 + 1 if pagecount % 5 > 0 else pagecount / 5)
if pagecount == 0:
return data
if pageNo == 6:
ct._write_tips(lines["pageHelp"].get("total"))
df = pd.DataFrame(lines["result"], columns=rv.MAR_SH_MX_COLS)
df["opDate"] = df["opDate"].map(lambda x: "%s-%s-%s" % (x[0:4], x[4:6], x[6:8]))
data = data.append(df, ignore_index=True)
if beginPage < datapage * 5:
data = _sh_mx(
data,
start=start,
end=end,
pageNo=pageNo,
beginPage=beginPage,
endPage=endPage,
retry_count=retry_count,
pause=pause,
)
except _network_error_classes:
pass
else:
return data
raise IOError(ct.NETWORK_URL_ERROR_MSG)
开发者ID:xyicheng，项目名称:tushare，代码行数:60，代码来源:reference.py
示例12: _newstocks
def _newstocks(data, pageNo, retry_count, pause):
for _ in range(retry_count):
time.sleep(pause)
ct._write_console()
try:
html = lxml.html.parse(rv.NEW_STOCKS_URL%(ct.P_TYPE['http'],ct.DOMAINS['vsf'],
ct.PAGES['newstock'], pageNo))
res = html.xpath('//table[@id=\"NewStockTable\"]/tr')
if len(res) == 0:
return data
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = sarr.replace('<font color="red">*</font>', '')
sarr = '<table>%s</table>'%sarr
df = pd.read_html(StringIO(sarr), skiprows=[0, 1])[0]
df = df.drop([df.columns[idx] for idx in [12, 13, 14]], axis=1)
df.columns = rv.NEW_STOCKS_COLS
df['code'] = df['code'].map(lambda x : str(x).zfill(6))
df['xcode'] = df['xcode'].map(lambda x : str(x).zfill(6))
res = html.xpath('//table[@class=\"table2\"]/tr[1]/td[1]/a/text()')
tag = '下一页' if ct.PY3 else unicode('下一页', 'utf-8')
hasNext = True if tag in res else False
data = data.append(df, ignore_index=True)
pageNo += 1
if hasNext:
data = _newstocks(data, pageNo, retry_count, pause)
except Exception as ex:
print(ex)
else:
return data
开发者ID:luodanzhi，项目名称:tushare，代码行数:33，代码来源:reference.py
示例13: _today_ticks
def _today_ticks(symbol, tdate, pageNo, retry_count, pause):
ct._write_console()
for _ in range(retry_count):
time.sleep(pause)
try:
html = lxml.html.parse(ct.TODAY_TICKS_URL % (ct.P_TYPE['http'],
ct.DOMAINS['vsf'], ct.PAGES['t_ticks'],
symbol, tdate, pageNo
))
res = html.xpath('//table[@id=\"datatbl\"]/tbody/tr')
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>'%sarr
sarr = sarr.replace('--', '0')
df = pd.read_html(StringIO(sarr), parse_dates=False)[0]
df.columns = ct.TODAY_TICK_COLUMNS
df['pchange'] = df['pchange'].map(lambda x : x.replace('%', ''))
except Exception as e:
print(e)
else:
return df
raise IOError(ct.NETWORK_URL_ERROR_MSG)
开发者ID:andyzsf，项目名称:PyTuShare，代码行数:25，代码来源:trading.py
示例14: _get_profit_data
def _get_profit_data(year, quarter, pageNo, dataArr):
url = ct.PROFIT_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]/a/text()')[0]
name = trs.xpath('td[2]/a/text()')[0]
roe = trs.xpath('td[3]/text()')[0]
roe = '0' if roe == '--' else roe
net_profit_ratio = trs.xpath('td[4]/text()')[0]
net_profit_ratio = '0' if net_profit_ratio == '--' else net_profit_ratio
gross_profit_rate = trs.xpath('td[5]/text()')[0]
gross_profit_rate = '0' if gross_profit_rate == '--' else gross_profit_rate
net_profits = trs.xpath('td[6]/text()')[0]
net_profits = '0' if net_profits == '--' else net_profits
eps = trs.xpath('td[7]/text()')[0]
eps = '0' if eps == '--' else eps
business_income = trs.xpath('td[8]/text()')[0]
business_income = '0' if business_income == '--' else business_income
bips = trs.xpath('td[9]/text()')[0]
bips = '0' if bips == '--' else bips
dataArr.append([code, name, roe, net_profit_ratio, gross_profit_rate,
net_profits, eps, business_income, bips])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_profit_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:34，代码来源:fundamental.py
示例15: _inst_detail
def _inst_detail(pageNo=1, retry_count=3, pause=0.001, dataArr=pd.DataFrame()):
ct._write_console()
for _ in range(retry_count):
time.sleep(pause)
try:
request = Request(rv.LHB_SINA_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], rv.LHB_KINDS[3],
ct.PAGES['fd'], '', pageNo))
text = urlopen(request, timeout=10).read()
text = text.decode('GBK')
html = lxml.html.parse(StringIO(text))
res = html.xpath("//table[@id=\"dataTable\"]/tr")
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>'%sarr
df = pd.read_html(sarr)[0]
df.columns = rv.LHB_JGMX_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick')
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _inst_detail(pageNo, retry_count, pause, dataArr)
else:
return dataArr
except Exception as e:
print(e)
开发者ID:280185386，项目名称:tushare，代码行数:28，代码来源:billboard.py
示例16: _get_cashflow_data
def _get_cashflow_data(year, quarter, pageNo, dataArr,
retry_count=3, pause=0.001):
ct._write_console()
for _ in range(retry_count):
time.sleep(pause)
try:
request = Request(ct.CASHFLOW_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'],
ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1]))
text = urlopen(request, timeout=10).read()
text = text.decode('GBK')
text = text.replace('--', '')
html = lxml.html.parse(StringIO(text))
res = html.xpath("//table[@class=\"list_table\"]/tr")
if ct.PY3:
sarr = [etree.tostring(node).decode('utf-8') for node in res]
else:
sarr = [etree.tostring(node) for node in res]
sarr = ''.join(sarr)
sarr = '<table>%s</table>'%sarr
df = pd.read_html(sarr)[0]
df.columns = ct.CASHFLOW_COLS
dataArr = dataArr.append(df, ignore_index=True)
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick')
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_cashflow_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except Exception as e:
pass
raise IOError(ct.NETWORK_URL_ERROR_MSG)
开发者ID:1FENQI，项目名称:tushare，代码行数:32，代码来源:fundamental.py
示例17: _get_debtpaying_data
def _get_debtpaying_data(year, quarter, pageNo, dataArr):
url = ct.DEBTPAYING_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]/a/text()')[0]
name = trs.xpath('td[2]/a/text()')[0]
currentratio = trs.xpath('td[3]/text()')[0]
currentratio = '0' if currentratio == '--' else currentratio
quickratio = trs.xpath('td[4]/text()')[0]
quickratio = '0' if quickratio == '--' else quickratio
cashratio = trs.xpath('td[5]/text()')[0]
cashratio = '0' if cashratio == '--' else cashratio
icratio = trs.xpath('td[6]/text()')[0]
icratio = '0' if icratio == '--' else icratio
sheqratio = trs.xpath('td[7]/text()')[0]
sheqratio = '0' if sheqratio == '--' else sheqratio
adratio = trs.xpath('td[8]/text()')[0]
adratio = '0' if adratio == '--' else adratio
dataArr.append([code, name, currentratio, quickratio, cashratio,
icratio, sheqratio, adratio])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_debtpaying_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:32，代码来源:fundamental.py
示例18: _get_cashflow_data
def _get_cashflow_data(year, quarter, pageNo, dataArr):
url = ct.CASHFLOW_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]/a/text()')[0]
name = trs.xpath('td[2]/a/text()')[0]
cf_sales = trs.xpath('td[3]/text()')[0]
cf_sales = '0' if cf_sales == '--' else cf_sales
rateofreturn = trs.xpath('td[4]/text()')[0]
rateofreturn = '0' if rateofreturn == '--' else rateofreturn
cf_nm = trs.xpath('td[5]/text()')[0]
cf_nm = '0' if cf_nm == '--' else cf_nm
cf_liabilities = trs.xpath('td[6]/text()')[0]
cf_liabilities = '0' if cf_liabilities == '--' else cf_liabilities
cashflowratio = trs.xpath('td[7]/text()')[0]
cashflowratio = '0' if cashflowratio == '--' else cashflowratio
dataArr.append([code, name, cf_sales, rateofreturn, cf_nm,
cf_liabilities, cashflowratio])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_cashflow_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:30，代码来源:fundamental.py
示例19: _get_operation_data
def _get_operation_data(year, quarter, pageNo, dataArr):
url = ct.OPERATION_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]/a/text()')[0]
name = trs.xpath('td[2]/a/text()')[0]
arturnover = trs.xpath('td[3]/text()')[0]
arturnover = '0' if arturnover == '--' else arturnover
arturndays = trs.xpath('td[4]/text()')[0]
arturndays = '0' if arturndays == '--' else arturndays
inventory_turnover = trs.xpath('td[5]/text()')[0]
inventory_turnover = '0' if inventory_turnover == '--' else inventory_turnover
inventory_days = trs.xpath('td[6]/text()')[0]
inventory_days = '0' if inventory_days == '--' else inventory_days
currentasset_turnover = trs.xpath('td[7]/text()')[0]
currentasset_turnover = '0' if currentasset_turnover == '--' else currentasset_turnover
currentasset_days = trs.xpath('td[8]/text()')[0]
currentasset_days = '0' if currentasset_days == '--' else currentasset_days
dataArr.append([code, name, arturnover, arturndays, inventory_turnover,
inventory_days, currentasset_turnover, currentasset_days])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_growth_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:32，代码来源:fundamental.py
示例20: _get_growth_data
def _get_growth_data(year, quarter, pageNo, dataArr):
url = ct.GROWTH_URL%(ct.P_TYPE['http'], ct.DOMAINS['vsf'], ct.PAGES['fd'], year,
quarter, pageNo, ct.PAGE_NUM[1])
ct._write_console()
try:
html = lxml.html.parse(url)
xtrs = html.xpath("//table[@class=\"list_table\"]/tr")
for trs in xtrs:
code = trs.xpath('td[1]/a/text()')[0]
name = trs.xpath('td[2]/a/text()')[0]
mbrg = trs.xpath('td[3]/text()')[0]
mbrg = '0' if mbrg == '--' else mbrg
nprg = trs.xpath('td[4]/text()')[0]
nprg = '0' if nprg == '--' else nprg
nav = trs.xpath('td[5]/text()')[0]
nav = '0' if nav == '--' else nav
targ = trs.xpath('td[6]/text()')[0]
targ = '0' if targ == '--' else targ
epsg = trs.xpath('td[7]/text()')[0]
epsg = '0' if epsg == '--' else epsg
seg = trs.xpath('td[8]/text()')[0]
seg = '0' if seg == '--' else seg
dataArr.append([code, name, mbrg, nprg, nav, targ, epsg, seg])
nextPage = html.xpath('//div[@class=\"pages\"]/a[last()]/@onclick') #获取下一页
if len(nextPage)>0:
pageNo = re.findall(r'\d+', nextPage[0])[0]
return _get_growth_data(year, quarter, pageNo, dataArr)
else:
return dataArr
except:
pass
开发者ID:sunlifeng，项目名称:tushare，代码行数:31，代码来源:fundamental.py
注：本文中的tushare.stock.cons._write_console函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论