# -*-coding=utf-8-*-

__author__ = 'Rocky'

'''

http://30daydo.com

Contact: weigesysu@qq.com

'''

#分析新股的开板时机

import tushare as ts

import os

import pandas as pd

import numpy as np

import matplotlib.pyplot as plt

class New_Stock_Break():

    def __init__(self):

        #为了文件整齐，新建一个文件夹data用来专门存放数据

        current = os.getcwd()

        folder = os.path.join(current, 'data')

        if os.path.exists(folder) == False:

            os.mkdir(folder)

        os.chdir(folder)

        #调用tushare接口，获取A股信息

        df0=ts.get_stock_basics()

        #df0=pd.read_csv('bases.csv',dtype={'code':np.str})

        self.bases=df0.sort_values('timeToMarket',ascending=False)



        #获取样本， 获取最近一个年的新股情况



        self.cxg=self.bases[(self.bases['timeToMarket']>20160101) & (self.bases['timeToMarket']<20170101)]

        self.codes= self.cxg['code'].values



    def calc_open_by_percent(self,code):

        cont=100000000

        #total_vol=self.bases[self.bases['code']==code]['totals'].values[0]

        acutal_vol=self.bases[self.bases['code']==code]['outstanding'].values[0]

        all_vol= acutal_vol*cont

        df1=ts.get_k_data(code)

        i=1

        while 1:

            s=df1.ix[1]

            if s['high']!=s['low']:

                #date=s['date']

                break

            i=i+1



        j=i-1

        date_end=df1.ix[j]['date']

        date_start=df1.ix[0]['date']

        df3=df1[(df1['date']>=date_start) & (df1['date']<=date_end)]

        v_total_break=df3['volume'].sum()

        l=len(df3)

        print l

        print v_total_break

        rate=v_total_break*100*100.00/all_vol #手和股 注意

        print round(rate,6)

        return rate,l





    def getData(self):

        result=

        max_line=

        k=

        for i in self.codes:

            print i

            name=self.bases[self.bases['code']==i]['name'].values[0]

            rate,l=self.calc_open_by_percent(i)

            if rate is not None:

                result.append(rate)

                max_line.append([name,l,rate])

                k.append(l)

        #写入文件

        f=open('2016-2017-cixin.csv','w')

        for x in max_line:

            #f.write(';'.join(x))

            f.write(x[0])

            f.write('-')

            f.write(str(x[1]))

            f.write('-')

            f.write(str(x[2]))

            f.write('\n')



        f.close()



def main():

    obj=New_Stock_Break()

    obj.testcase2()



main()

 
运行后得到的数据如下：

 

    def Trade_list(self, coin):

        '''

        Trade_list（挂单查询）

        您指定时间后的挂单，可以根据类型查询，比如查看正在挂单和全部挂单

        Path：/api/v1/trade_list/

        Request类型：POST

        参数

        key - API key

        signature - signature

        nonce - nonce

        since - unix timestamp(utc timezone) default == 0, i.e. 返回所有

        coin - 币种简称,例如btc、ltc、xas

        type - 挂单类型[open:正在挂单, all:所有挂单]



        返回JSON dictionary

        id - 挂单ID

        datetime - date and time

        type - "buy" or "sell"

        price - price

        amount_original - 下单时数量

        amount_outstanding - 当前剩余数量

        '''

        url = self.host + '/api/v1/trade_list/'

        time.sleep(random.random())

        nonce = self.get_nonce_time()

        types = 'all'

        since = 0

        parameters = {'key': self.public_key, 'nonce': str(nonce), 'type': types, 'coin': coin, 'signature': ''}

        # print parameters

        post_data = ''

        for k, v in parameters.items():

            if not isinstance(v, str):

                #if type(v) is not types.StringType:

                v = str(v)

            post_data = post_data + k

            post_data = post_data + '=' + v + '&'



        #print 'post-data:\n',post_data

        post_data = post_data[:-1]

        post_data = post_data.replace('&signature=', '')

        #print post_data



        signature = hmac.new(self.md5, post_data, digestmod=hashlib.sha256).digest()

        sig = self.toHex(signature)

        parameters['signature'] = sig

        #print parameters

        r = requests.post(url=url, data=parameters)

        s = r.json()

        #print s

        return s

一、API使用说明

1、请求过程说明

1.1 构造请求数据，用户数据按照Jubi提供的接口规则，通过程序生成签名和要传输给Jubi的数据集合；

1.2 发送请求数据，把构造完成的数据集合通过POST/GET提交的方式传递给Jubi；

1.3 Jubi对请求数据进行处理，服务器在接收到请求后，会首先进行安全校验，验证通过后便会处理该次发送过来的请求；

1.4 返回响应结果数据，Jubi把响应结果以JSON的格式反馈给用户，具体的响应格式，错误代码参见接口部分；

1.5 对获取的返回结果数据进行处理；

2、安全认证

所有的private API都需要经过认证

Api的申请可以到财务中心 -> API，申请得到私钥和公钥，私钥Jubi将不做储存，一旦丢失将无法找回

注意:请勿向任何人泄露这两个参数，这像您的密码一样重要

2.签名机制

每次请求private api 都需要验证签名，发送的参数示例：

$param = array(

amount => 1,

price => 10000,

type => 'buy',

nonce => 141377098123

key => 5zi7w-4mnes-swmc4-egg9b-f2iqw-396z4-g541b

signature => 459c69d25c496765191582d9611028b9974830e9dfafd762854669809290ed82

);

nonce 可以理解为一个递增的整数：http://zh.wikipedia.org/wiki/Nonce

key 是申请到的公钥

signature是签名，是将amount price type nonce key等参数通过'&'字符连接起来通过md5(私钥)为key进行sha256算法加密得到的值.

 

    def real_time_ticker(coin):

        url = 'https://www.jubi.com/api/v1/ticker/'

        try:

            data = requests.post(url, data={'coin': coin}).json()

            

        except Exception ,e:

            print e

        return data

{u'sell': u'0.179000', u'volume': 21828245.102822, u'buy': u'0.175010', u'last': u'0.179000', u'vol': 108290769.9171, u'high': u'0.289000', u'low': u'0.119141'}

每次请求private api 都需要验证签名，发送的参数示例：

$param = array(

amount => 1,

price => 10000,

type => 'buy',

nonce => 141377098123

key => 5zi7w-4mnes-swmc4-egg9b-f2iqw-396z4-g541b

signature => 459c69d25c496765191582d9611028b9974830e9dfafd762854669809290ed82

);

nonce 可以理解为一个递增的整数：http://zh.wikipedia.org/wiki/Nonce

key 是申请到的公钥

signature是签名，是将amount price type nonce key等参数通过'&'字符连接起来通过md5(私钥)为key进行sha256算法加密得到的值.

Trade_add（下单）
Path：/api/v1/trade_add/
Request类型：POST
 
参数
key - API key
signature - signature
nonce - nonce
amount - 购买数量
price - 购买价格
type - 买单或者卖单
coin - 币种简称,例如btc、ltc、xas
id - 挂单ID
result - true(成功), false(失败)
{"result":true, "id":"11"}
 
返回JSON dictionary
id - 挂单ID
result - true(成功), false(失败)
 
返回结果示例：
{"result":true, "id":"11"}
 

    def get_nonce(self):

        lens=12

        return ''.join([str(random.randint(0, 9)) for i in range(lens)])

    def get_nonce_time(self):

        lens = 12

        curr_stamp = time.time()*100

        nonece=int(curr_stamp)

        return nonece

    def getHash(self,s):

        m=hashlib.md5()

        m.update(s)

        return m.hexdigest()

nonce=self.get_nonce_time

type='buy'

amount='10000'

key='xxxxxxxxxxx‘  #这个是聚币网给你的公钥，同样在设置里头可以找到

price='10' #你要设置的价格为10

coin='zet'

message = "amount=“+amount+”&nonce="+str(nonce)+"&type="+type+"&key="+key+'&price="+price+"&coin"+coin

 

signature = hmac.new(sha_256key, message, digestmod=hashlib.sha256).digest()



这样获得signature之后，就可以通过签名来进行post操作。

 

data_wrap={'nonce':nonce,'key':key_value,'signature':signature}

 

js=requests.post(url,data=data_wrap).json()

    def toHex(self,str):

        lst = 

        for ch in str:

            hv = hex(ord(ch)).replace('0x', '')

            if len(hv) == 1:

                hv = '0' + hv

            lst.append(hv)

        return reduce(lambda x, y: x + y, lst)

    def getAccount(self):

        url='https://www.jubi.com/api/v1/balance/'



        nonce_value=self.get_nonce_time()

        print nonce_value

        key_value=self.public_key

        private_key=self.private_key



        s='nonce='+str(nonce_value)+'&'+'key='+key_value



        print s



        #signature是签名，是将amount price type nonce key等参数通过'&'字符连接起来通过md5(私钥)为key进行sha256算法加密得到的值.

        md5=self.getHash(private_key)

        print md5

        print type(md5)



        msg=bytes(s).encode('utf-8')

        key=bytes(md5).encode('utf-8')

        signature =hmac.new(key,msg,digestmod=hashlib.sha256).digest()

        print signature

        print type(signature)

        sig=self.toHex(signature)



        print sig

        data_wrap={'nonce':nonce_value,'key':key_value,'signature':sig}



        print data_wrap



        data_en=urllib.urlencode(data_wrap)

        req=urllib2.Request(url,data=data_en)

        resp=urllib2.urlopen(req).read()

        print resp





    def toHex(self,str):

        lst = 

        for ch in str:

            hv = hex(ord(ch)).replace('0x', '')

            if len(hv) == 1:

                hv = '0' + hv

            lst.append(hv)

        return reduce(lambda x, y: x + y, lst)

{"uid":123456,"nameauth":1,"moflag":1,"asset":,"btc_balance":0,"btc_lock":0,"drk_balance":0,"drk_lock":0,"blk_balance":0,"blk_lock":0,"vrc_balance":0,"vrc_lock":0,"tfc_balance":0,"tfc_lock":0,"jbc_balance":0,"jbc_lock":0,"ltc_balance":0,"ltc_lock":0,"doge_balance":0,"doge_lock":0,"xpm_balance":0,"xpm_lock":0,"ppc_balance":0,"ppc_lock":0,"wdc_balance":0,"wdc_lock":0,"vtc_balance":0,"vtc_lock":0,"max_balance":0,"max_lock":0,"ifc_balance":0,"ifc_lock":0,"zcc_balance":0,"zcc_lock":0,"zet_balance":0,"zet_lock":0,"eac_balance":0,"eac_lock":0,"fz_balance":0,"fz_lock":0,"skt_balance":0,"skt_lock":0,"plc_balance":0,"plc_lock":0,"mtc_balance":0,"mtc_lock":0,"qec_balance":0,"qec_lock":0,"lkc_balance":10,"lkc_lock":0,"met_balance":0,"met_lock":0,"ytc_balance":0,"ytc_lock":0,"hlb_balance":0,"hlb_lock":0,"game_balance":0,"game_lock":0,"rss_balance":0,"rss_lock":0,"rio_balance":0,"rio_lock":0,"ktc_balance":0,"ktc_lock":0,"pgc_balance":0,"pgc_lock":0,"mryc_balance":0,"mryc_lock":0,"eth_balance":0,"eth_lock":0,"etc_balance":0,"etc_lock":0,"dnc_balance":0,"dnc_lock":0,"gooc_balance":0,"gooc_lock":0,"xrp_balance":0,"xrp_lock":0,"nxt_balance":0,"nxt_lock":0,"lsk_balance":0,"lsk_lock":0,"xas_balance":0,"xas_lock":0,"peb_balance":0,"peb_lock":0,"nhgh_balance":0,"nhgh_lock":0,"xsgs_balance":0,"xsgs_lock":0,"ans_balance":0,"ans_lock":0,"bts_balance":0,"bts_lock":0,"cny_balance":0,"cny_lock":0}

# -*-coding=utf-8-*-

__author__ = 'Rocky'

#计算某个股票的某个时间段的成交量

import  tushare as ts

import pandas as pd

import datetime

pd.set_option('display.max_rows',None)

class amount_calculation():

    def __init__(self,code):

        self.df=ts.get_today_ticks(code)



        #转换str为时间格式，便于下面用来比较时间的大小

        self.df['time']=self.df['time'].map(lambda x:datetime.datetime.strptime(str(x),'%H:%M:%S'))

        print '\n'

        self.total= self.df['volume'].sum()



    def calc(self,start,end):

        s0=datetime.datetime.strptime(start,'%H:%M:%S')

        e0=datetime.datetime.strptime(end,'%H:%M:%S')

        new_df=self.df[(self.df['time']>=s0) & (self.df['time']<e0) ]

        part=new_df['volume'].sum()

        print part

        rate=round(part*1.00/self.total*100,2)

        print rate

        return rate









def main():

    obj=amount_calculation('600908')

    #s1=obj.calc('09:24:00','10:30:00')

    #s2=obj.calc('10:30:00','11:30:00')

    #s3=obj.calc('13:00:00','14:00:00')

    s4=obj.calc('14:35:00','15:05:00')

    #print s1+s2+s3+s4



main()

    c=[2,4,6,8,10,12,14,16,18]

    d= [i*2 for i in c]

    print d

    s1=Series(c) #转为series类型

    s2=Series(d)

    corr=s1.corr(s2) #计算相关系数

    print corr

c=[2,4,6,8,10,12,14,16,18]

    d= [i*2 for i in c]

    print d

    d[0]=3 # 修改d[0]的值

    s1=Series(c) #转为series类型

    s2=Series(d)

    corr=s1.corr(s2) #计算相关系数

    print corr

code	name	industry	area	pe

300554	N三超	矿物制品	江苏	29.61

300642	N透景	医疗保健	上海	61.54

603232	N格尔	软件服务	上海	90.56

300645	N正元	软件服务	浙江	25.91

603139	N康惠	中成药	陕西	55.73

603803	瑞斯康达	通信设备	北京	38.44

603081	大丰实业	专用机械	浙江	45.08

603225	新凤鸣	化纤	浙江	42.08

300641	正丹股份	化工原料	江苏	38.94

2863	今飞凯达	汽车配件	浙江	31.84

300604	长川科技	专用机械	浙江	95.26

300640	德艺文创	文教休闲	福建	35.7

603050	科林电气	电气设备	河北	47.81

603826	坤彩科技	染料涂料	福建	52.14

2861	瀛通通讯	通信设备	湖北	51.85

603797	联泰环保	环境保护	广东	58.78

300638	广和通	通信设备	深圳	52.89

300637	扬帆新材	化工原料	浙江	55.99

300639	凯普生物	医疗保健	广东	61.02

601366	利群股份	百货	山东	40.83

2860	星帅尔	电气设备	浙江	52.09

2862	实丰文化	文教休闲	广东	68.85

603078	江化微	化工原料	江苏	54.32

603906	龙蟠科技	化工原料	江苏	61.42

2859	洁美科技	元器件	浙江	49.76

603538	美诺华	化学制药	浙江	53.68

300632	光莆股份	半导体	福建	81.71

603586	金麒麟	汽车配件	山东	40.05

300633	开立医疗	医疗保健	深圳	66.58

603385	惠达卫浴	家居用品	河北	38.55

300636	同和药业	化学制药	江西	55.38

300635	达安股份	建筑施工	广东	56.56

601200	上海环境	环境保护	上海	47.28

603303	得邦照明	家用电器	浙江	28.1

603041	美思德	化工原料	江苏	49.15

601228	广州港	港口	广东	89.91

300630	普利制药	化学制药	海南	69.51

603833	欧派家居	家居用品	广东	46.35

603178	圣龙股份	汽车配件	浙江	53.06

603717	天域生态	环境保护	重庆	52.39

603388	元成股份	建筑施工	浙江	63.46

300629	新劲刚	矿物制品	广东	126.05

603768	常青股份	汽车配件	安徽	43.04

2774	快意电梯	运输设备	广东	58.63

2858	力盛赛车	文教休闲	上海	102.63

300631	久吾高科	环境保护	江苏	72.98

2857	三晖电气	电器仪表	河南	0

2855	捷荣技术	塑料	广东	69.55

603656	泰禾光电	专用机械	安徽	53.82

300627	华测导航	通信设备	上海	67.46

2856	美芝股份	装修装饰	深圳	63.78

300626	华瑞股份	电气设备	浙江	81.05

603133	碳元科技	元器件	江苏	72.88

300625	三雄极光	半导体	广东	45.17

603517	绝味食品	食品	湖南	43.74

603179	新泉股份	汽车配件	江苏	61.57

300628	亿联网络	通信设备	福建	55.24

300621	维业股份	装修装饰	深圳	64.14

300622	博士眼镜	其他商业	深圳	82.66

603811	诚意药业	化学制药	浙江	73.4

603960	克来机电	专用机械	上海	99.88

603903	中持股份	环境保护	北京	103.18

300623	捷捷微电	半导体	江苏	50.98

603630	拉芳家化	日用化工	广东	49.94

603665	康隆达	纺织	浙江	49.4

2852	道道全	食品	湖南	44.89

2853	皮阿诺	家居用品	广东	55.15

603955	大千生态	环境保护	江苏	59.15

300620	光库科技	元器件	广东	73.33

603991	至正股份	塑料	上海	84.99

603908	牧高笛	纺织	浙江	74.17

300616	尚品宅配	家居用品	广东	59.29

2851	麦格米特	电气设备	深圳	73

603578	三星新材	玻璃	浙江	105.85

603138	海量数据	软件服务	北京	135.21

300618	寒锐钴业	小金属	江苏	133.38

2850	科达利	机械基件	深圳	55.29

300619	金银河	专用机械	广东	246.98

300617	安靠智电	电气设备	江苏	65.97

603238	诺邦股份	纺织	浙江	62.94

603345	安井食品	食品	福建	54.28

600939	重庆建工	建筑施工	重庆	82.74

603817	海峡环保	环境保护	福建	83.99

300613	富瀚微	半导体	上海	67.63

300611	美力科技	机械基件	浙江	67.94

2849	威星智能	电器仪表	浙江	86.25

603603	博天环境	环境保护	北京	111.4

601212	白银有色	铜	甘肃	265.03

300609	汇纳科技	互联网	上海	82.01

300615	欣天科技	元器件	深圳	55.67

300612	宣亚国际	广告包装	北京	195.12

603839	安正时尚	服饰	浙江	37.3

603615	茶花股份	塑料	福建	57.4

603330	上海天洋	塑料	上海	64.02

300610	晨化股份	化工原料	江苏	54.18

300608	思特奇	软件服务	北京	61.78

2848	高斯贝尔	通信设备	湖南	65.19

603208	江山欧派	家居用品	浙江	38.24

603626	科森科技	专用机械	江苏	153.86

603040	新坐标	机械基件	浙江	80.74

300607	拓斯达	专用机械	广东	103.38

300605	恒锋信息	软件服务	福建	79.72

603637	镇海股份	建筑施工	浙江	72.58

300606	金太阳	矿物制品	广东	77.25

2847	盐津铺子	食品	湖南	70.34

603881	数据港	互联网	上海	118.22

300601	康泰生物	生物制药	深圳	112.28

603177	德创环保	环境保护	浙江	112.99

2846	英联股份	广告包装	广东	118.72

603677	奇精机械	机械基件	浙江	46.51

603360	百傲化学	化工原料	辽宁	44.71

300602	飞荣达	元器件	深圳	44.98

300603	立昂技术	通信设备	新疆	124.24

603089	正裕工业	汽车配件	浙江	43.63

603358	华达科技	汽车配件	江苏	30.03

2845	同兴达	元器件	深圳	110.36

603966	法兰泰克	机械基件	江苏	82.08

300578	会畅通讯	通信设备	上海	97.19

300600	瑞特股份	电气设备	江苏	55.45

2839	张家港行	银行	江苏	46.6

603429	集友股份	广告包装	安徽	92.59

601881	中国银河	证券	北京	24.02

300599	雄塑科技	塑料	广东	65.11

300597	吉大通信	通信设备	吉林	96.6

2843	泰嘉股份	钢加工	湖南	140.16

300592	华凯创意	软件服务	湖南	0

603037	凯众股份	汽车配件	上海	40.72

300598	诚迈科技	软件服务	江苏	69.49

603638	艾迪精密	专用机械	山东	38.92

2841	视源股份	元器件	广东	46.85

2842	翔鹭钨业	小金属	广东	63.53

603337	杰克股份	纺织机械	浙江	29.96

300596	利安隆	化工原料	天津	47.69

601858	中国科传	出版业	北京	95.28

300595	欧普康视	医疗保健	安徽	55.35

603668	天马科技	饲料	福建	58.17

603165	荣晟环保	造纸	浙江	48.2

603038	华立股份	装修装饰	广东	35.91

300589	江龙船艇	船舶	广东	113.92

603039	泛微网络	软件服务	上海	73.71

603690	至纯科技	专用机械	上海	79.65

300593	新雷能	电气设备	北京	77.11

603628	清源股份	电气设备	福建	107.13

2824	和胜股份	铝	广东	56.15

603639	海利尔	农药化肥	山东	44.23

300584	海辰药业	化学制药	江苏	76.64

300590	移为通信	通信设备	上海	55.19

300580	贝斯特	汽车配件	江苏	43.14

603579	荣泰健康	医疗保健	上海	45.21

2840	华统股份	食品	浙江	52.47

603266	天龙股份	塑料	浙江	48.58

603689	皖天然气	供气供热	安徽	61.81

300591	万里马	服饰	广东	126.22

603877	太平鸟	服饰	浙江	35.34

300583	赛托生物	生物制药	山东	67.33

603228	景旺电子	元器件	深圳	32.84

2838	道恩股份	塑料	山东	66.23

603032	德新交运	公路	新疆	84.36

300587	天铁股份	橡胶	浙江	54.16

603035	常熟汽饰	汽车配件	江苏	29.44

300588	熙菱信息	软件服务	新疆	758.5

603444	吉比特	互联网	福建	35.29

300586	美联新材	化工原料	广东	67.93

601375	中原证券	证券	河南	54.87

603186	华正新材	元器件	浙江	52.86

d=np.array([1, 2, 3，4,5 ])

print d

e=d.tolist()

print e

d=np.array([1, 2, 3，4,5 ])

print d

e=list(d)

print e

lst=[1, 2, 3，4,5 ]

d=np.array(lst)

    base=ts.get_stock_basics()

    base.to_csv('2.xls')

    base.to_excel('base.xls',encoding='GBK')

    base.to_excel('111.xls',encoding='utf8')

    base.to_excel('111.xls‘)

import tushare as ts



ts.get_stock_basics()

    self.base=ts.get_stock_basics()

  File "C:\Python27\lib\site-packages\tushare\stock\fundamental.py", line 44, in get_stock_basics

    text = urlopen(request, timeout=10).read()

  File "C:\Python27\lib\socket.py", line 351, in read

    data = self._sock.recv(rbufsize)

  File "C:\Python27\lib\httplib.py", line 567, in read

    s = self.fp.read(amt)

  File "C:\Python27\lib\socket.py", line 380, in read

    data = self._sock.recv(left)

socket.timeout: timed out

pip install tushare --upgrade

    def count_area():

        base=ts.get_stock_basics()

        count=base['area'].value_counts()

        ＃这一句的意思，就是获取所有股票的上市地区的数据，然后计算出现的次数

        print count

        print type(count)

Password:

The directory '/Users/rocky/Library/Caches/pip/http' or its parent directory is not owned by the current user and the cache has been disabled. Please check the permissions and owner of that directory. If executing pip with sudo, you may want sudo's -H flag.

The directory '/Users/rocky/Library/Caches/pip' or its parent directory is not owned by the current user and caching wheels has been disabled. check the permissions and owner of that directory. If executing pip with sudo, you may want sudo's -H flag.

Requirement already satisfied: matplotlib in /System/Library/Frameworks/Python.framework/Versions/2.7/Extras/lib/python

Requirement already satisfied: numpy>=1.5 in /System/Library/Frameworks/Python.framework/Versions/2.7/Extras/lib/python (from matplotlib)

Requirement already satisfied: python-dateutil in /System/Library/Frameworks/Python.framework/Versions/2.7/Extras/lib/python (from matplotlib)

Collecting tornado (from matplotlib)

  Downloading tornado-4.4.3.tar.gz (463kB)

    100% |████████████████████████████████| 471kB 84kB/s 

Requirement already satisfied: pyparsing>=1.5.6 in /System/Library/Frameworks/Python.framework/Versions/2.7/Extras/lib/python (from matplotlib)

Collecting nose (from matplotlib)

  Downloading nose-1.3.7-py2-none-any.whl (154kB)

    100% |████████████████████████████████| 163kB 75kB/s 

Collecting singledispatch (from tornado->matplotlib)

  Downloading singledispatch-3.4.0.3-py2.py3-none-any.whl

Collecting certifi (from tornado->matplotlib)

  Downloading certifi-2017.1.23-py2.py3-none-any.whl (382kB)

    100% |████████████████████████████████| 389kB 105kB/s 

Collecting backports_abc>=0.4 (from tornado->matplotlib)

  Downloading backports_abc-0.5-py2.py3-none-any.whl

Requirement already satisfied: six in /System/Library/Frameworks/Python.framework/Versions/2.7/Extras/lib/python (from singledispatch->tornado->matplotlib)

Installing collected packages: singledispatch, certifi, backports-abc, tornado, nose

  Running setup.py install for tornado ... done

Exception:

Traceback (most recent call last):

  File "/Library/Python/2.7/site-packages/pip/basecommand.py", line 215, in main

    status = self.run(options, args)

  File "/Library/Python/2.7/site-packages/pip/commands/install.py", line 342, in run

    prefix=options.prefix_path,

  File "/Library/Python/2.7/site-packages/pip/req/req_set.py", line 784, in install

    **kwargs

  File "/Library/Python/2.7/site-packages/pip/req/req_install.py", line 851, in install

    self.move_wheel_files(self.source_dir, root=root, prefix=prefix)

  File "/Library/Python/2.7/site-packages/pip/req/req_install.py", line 1064, in move_wheel_files

    isolated=self.isolated,

  File "/Library/Python/2.7/site-packages/pip/wheel.py", line 377, in move_wheel_files

    clobber(source, dest, False, fixer=fixer, filter=filter)

  File "/Library/Python/2.7/site-packages/pip/wheel.py", line 316, in clobber

    ensure_dir(destdir)

  File "/Library/Python/2.7/site-packages/pip/utils/__init__.py", line 83, in ensure_dir

    os.makedirs(path)

  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/os.py", line 150, in makedirs

    makedirs(head, mode)

  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/os.py", line 157, in makedirs

    mkdir(name, mode)

OSError: [Errno 1] Operation not permitted: '/System/Library/Frameworks/Python.framework/Versions/2.7/man'

    def get_achievement(self):

        fc=ts.forecast_data(2016,4)

        print fc

    def get_achievement(self):



        fc=ts.forecast_data(2016,4)

        pandas.set_option('display.max_rows',None)

        print fc

from sklearn import svm

import numpy as np



def main():

    preTime = 0

    n = 0

    success = 0

    predict = None

    pTime = None

    marketPosition = 0

    initAccount = exchange.GetAccount()

    Log("Running...")

    while True:

        r = exchange.GetRecords()

        if len(r) < 60:

            continue

        bar = r[len(r)-1]

        if bar.Time > preTime:

            preTime = bar.Time

            if pTime is not None and r[len(r)-2].Time == pTime:

                diff = r[len(r)-2].Close - r[len(r)-3].Close

                if diff > SpreadVal:

                    success += 1 if predict == 0 else 0

                elif diff < -SpreadVal:

                    success += 1 if predict == 1 else 0

                else:

                    success += 1 if predict == 2 else 0

                pTime = None

                LogStatus("预测次数", n, "成功次数", success, "准确率:", '%.3f %%' % round(float(success) * 100 / n, 2))

        else:

            Sleep(1000)

            continue

        inputs_X, output_Y = , 

        sets = [None, None, None]

        for i in xrange(1, len(r)-2, 1):

            inputs_X.append([r[i].Open, r[i].Close])

            Y = 0

            diff = r[i+1].Close - r[i].Close

            if diff > SpreadVal:

                Y = 0

                sets[0] = True

            elif diff < -SpreadVal:

                Y = 1

                sets[1] = True

            else:

                Y = 2

                sets[2] = True

            output_Y.append(Y)

        if None in sets:

            Log("样本不足, 无法预测 ...")

            continue

        n += 1

        clf = svm.LinearSVC()

        clf.fit(inputs_X, output_Y)

        predict = clf.predict(np.array([bar.Open, bar.Close]).reshape((1, -1)))

        pTime = bar.Time

        

        Log("预测当前Bar结束:", bar.Time, ['涨', '跌', '横'][predict])

        if marketPosition == 0:

            if predict == 0:

                exchange.Buy(initAccount.Balance/2)

                marketPosition = 1

            elif predict == 1:

                exchange.Sell(initAccount.Stocks/2)

                marketPosition = -1

        else:

            nowAccount = exchange.GetAccount()

            if marketPosition > 0 and predict != 0:

                exchange.Sell(nowAccount.Stocks - initAccount.Stocks)

                nowAccount = exchange.GetAccount()

                marketPosition = 0

            elif marketPosition < 0 and predict != 1:

                while True:

                    dif = initAccount.Stocks - nowAccount.Stocks

                    if dif < 0.01:

                        break

                    ticker = exchange.GetTicker()

                    exchange.Buy(ticker.Sell + (ticker.Sell-ticker.Buy)*2, dif)

                    while True:

                        Sleep(1000)

                        orders = exchange.GetOrders()

                        for order in orders:

                            exchange.CancelOrder(order.Id)

                        if len(orders) == 0:

                            break

                    nowAccount = exchange.GetAccount()

                marketPosition = 0

            if marketPosition == 0:

                LogProfit(_N(nowAccount.Balance - initAccount.Balance, 4), nowAccount)

                [/i][/i]

data=pd.DataFrame(np.arange(16).reshape(4,4),index=['Ohio','Colorado','Utah','New York'],columns=['one','two','three','four'])

>>> data

          one  two  three  four

Ohio        0    1      2     3

Colorado    4    5      6     7

Utah        8    9     10    11

New York   12   13     14    15

data.ix[:'Utah',:2]

          one  two

Ohio        0    1

Colorado    4    5

Utah        8    9

data.ix[:'Utah',:'two']

          one  two

Ohio        0    1

Colorado    4    5

Utah        8    9

session=requests.session()

#先创建一个seession



s=session.get('http://xueqiu.com',headers=self.headers)

#随意建立一个访问雪球的session，此时的session就自带了雪球的cookies



url='https://xueqiu.com/snowmart/push/stocks.json?product_id=19&page=3&count=5'

headers['Referer']='https://xueqiu.com/strategy/19'

headers['X-Requested-With']='XMLHttpRequest'

headers['DNT']='1'



data={'product_id':19,'page':3,'count':5}



resp=session.get(url,headers=self.headers,params=data).text

#如果这里用的request.get的话，就不能获取到网页返回的正确内容

print resp

def csdn():

    session=requests.session()

    header={'User-Agent':'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/52.0.2743.82 Safari/537.36'}

    url='[url]http://msg.csdn.net/'[/url] 

    header['Cookie']='uuid_tt_dd=-5697318013068753627_20160111; _ga=GA1.2.795042232.1452766190; _message_m=quvq2wle24wa4awe UserInfo=zMhiNgesgIlEBQ3TOqLCtx4nUI360IIq3ciBzg4EKH%2FW8mSpTANpu5cTlRFLj2Tqh%2FZzQr2rNqDtT1SZz%2Be2%2FpDkGoQxDK3IVUZXvwZ%2FEP1I4UTg6MoZkH7LDO3sjrJJ; UserNick=%E9%87%8D%E5%A4%8D%E7%9A%84%E7%94%9F%E6%B4%BB; AU=0F1; UD=%E8%AE%B0%E5%BD%95%E8%87%AA%E5%AD%A6%E7%9A%84%E5%8E%86%E7%A8%8B+%E5%88%83%E8%8D%; BT=1490707396344; access-token=c2e12bff-5b27-4a91-953b-448ff6f6beac; _csdn_notify_admin_session=VE41a0d3TitrVGY2bGtXY09pZENwR1lHenhUU1NVaWc1b04wL1I3dCtDQVdadWpjMXBzdGRJL0RZR04wYldvZDBhTU96b2oycVVKeVI1UEVyUHFKbG1yNnB2b2pHRWVnWG1uc2JMM2R3YWthakRyTXZNaEpVU1NtUy9zQUJrNjd3R2lpbG5PK0paMnlyc1dyK0lTZUtRPT0tLXlPQUE1QzF5UmhDNjEvSFdtRFlQS2c9PQ%3D%3D--4569c5a32916dcf969a8b7e007c37abeb90be4f3; dc_tos=onj1dg; dc_session_id=1490707393375; Hm_lvt_6bcd52f51e9b3dce32bec4a3997715ac=1490024083,1490024559,1490374375,1490707368; Hm_lpvt_6bcd52f51e9b3dce32bec4a3997715ac=1490707638'

    header['Cache-Control']='max-age=0'

    header['Host']='msg.csdn.net'

    header['Referer']='http://blog.csdn.net/username'

    resp=requests.get(url,headers=header)

    print resp.text

 
上面这段代码，只要你改一下cookie和 Refer 的连接，改成你自己的用户名。 你就可以访问你的csdn的消息，也就是别人在你的csdn博客访问的的留言，评论。
 
只是这个cookie只能在某个时间段生效，也就是存活期大概就一个星期左右。

def taobao_shiyong():



    d.screen.on()

    d.press.home()



    activity_name='com.taobao.taobao/com.taobao.tao.homepage.MainActivity3'

    launch_app(activity_name)

    mid_x=displayWidth/2



    try:



        d(text=u'我的淘宝').click()

        time.sleep(3)

        d(text='查看更多工具').click()

        time.sleep(3)

        d(scrollable=True).scroll.to(text=u'免费试用')

        time.sleep(2)

        d(text=u'免费试用').click()

        time.sleep(3)





        delta_y=144

        full_y=1920

        full_x=1080

        fix_x=880

        origin_y=222

        d.swipe(fix_x,full_y-delta_y,fix_x,origin_y)

        time.sleep(3)

        #d.swipe(fix_x,952,fix_x,origin_y)

        time.sleep(5)



        sumakeji=displayWidth/8*3

        jiayongdianqi=displayWidth/8*5

        d.click(jiayongdianqi,1660)

        time.sleep(3)



        #each_dianpu()

        #d.click(jiayongdianqi,300)



        delta_each=400

        time.sleep(3)



        for dragtime in range(20):

            for i in range(3):

                d.click(919,600+i*delta_each)

                time.sleep(8)

                each_dianpu()



            d.swipe(919,1600,919,400)



    except:

        print "Can't find items"