code/dataapi.py · timeroses/pythoncoding

代码拉取完成,页面将自动刷新

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 0

timeroses/pythoncoding

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

master

分支 (1)

管理

master

该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。

项目仓库所选许可证以仓库主分支所使用许可证为准

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 1

标签 0

pythoncoding

code

dataapi.py

dataapi.py 2.55 KB

# -*- coding: utf-8 -*-
import httplib
import traceback
import urllib
HTTP_OK = 200
HTTP_AUTHORIZATION_ERROR = 401
class Client:
 domain = 'api.wmcloud.com'
 port = 443
 token = ''
 httpClient = None
 #设置因网络连接,重连的次数
 reconnectTimes=3
 def __init__( self ):
 self.httpClient = httplib.HTTPSConnection(self.domain, self.port, timeout=60)
 def __del__( self ):
 if self.httpClient is not None:
 self.httpClient.close()
 def encodepath(self, path):
 #转换参数的编码
 start=0
 n=len(path)
 re=''
 i=path.find('=',start)
 if(i==-1):
 return path
 while i!=-1 :
 re+=path[start:i+1]
 start=i+1
 i=path.find('&',start)
 if(i>=0):
 for j in range(start,i):
 if(path[j]>'~'):
 re+=urllib.quote(path[j])
 else:
 re+=path[j]
 re+='&'
 start=i+1
 else:
 for j in range(start,n):
 if(path[j]>'~'):
 re+=urllib.quote(path[j])
 else:
 re+=path[j]
 start=n
 i=path.find('=',start)
 return re
 def init(self, token):
 self.token=token
 def getData(self, path):
 result = None
 path='/data/v1'+path
 path=self.encodepath(path)
 print path
 for i in range(self.reconnectTimes):
 try:
 #set http header here
 self.httpClient.request('GET', path, headers = {"Authorization": "Bearer " + self.token})
 #make request
 response = self.httpClient.getresponse()
 #read result
 if response.status == HTTP_OK:
 #parse json into python primitive object
 result = response.read()
 else:
 result = response.read()
 if(path.find('.csv?')==-1):
 result=result.decode('utf-8').encode('GB18030')
 return response.status, result
 except Exception, e:
 #网络连接失败,关闭当前连接,再重新建立
 print i
 if self.httpClient is not None:
 self.httpClient.close()
 self.httpClient = httplib.HTTPSConnection(self.domain, self.port, timeout=60)
 return -1,'cannot connect '+str(self.reconnectTimes)+' times'

一键复制编辑原始数据按行查看历史

timeroses 提交于 2017年10月10日 13:27 +08:00 . first vision

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76

# -*- coding: utf-8 -*-
import httplib
import traceback
import urllib
HTTP_OK = 200
HTTP_AUTHORIZATION_ERROR = 401
class Client:
 domain = 'api.wmcloud.com'
 port = 443
 token = ''
 httpClient = None
 #设置因网络连接,重连的次数
 reconnectTimes=3
 def __init__( self ):
 self.httpClient = httplib.HTTPSConnection(self.domain, self.port, timeout=60)
 def __del__( self ):
 if self.httpClient is not None:
 self.httpClient.close()
 def encodepath(self, path):
 #转换参数的编码
 start=0
 n=len(path)
 re=''
 i=path.find('=',start)
 if(i==-1):
 return path
 while i!=-1 :
 re+=path[start:i+1]
 start=i+1
 i=path.find('&',start)
 if(i>=0):
 for j in range(start,i):
 if(path[j]>'~'):
 re+=urllib.quote(path[j])
 else:
 re+=path[j]
 re+='&'
 start=i+1
 else:
 for j in range(start,n):
 if(path[j]>'~'):
 re+=urllib.quote(path[j])
 else:
 re+=path[j]
 start=n
 i=path.find('=',start)
 return re
 def init(self, token):
 self.token=token
 def getData(self, path):
 result = None
 path='/data/v1'+path
 path=self.encodepath(path)
 print path
 for i in range(self.reconnectTimes):
 try:
 #set http header here
 self.httpClient.request('GET', path, headers = {"Authorization": "Bearer " + self.token})
 #make request
 response = self.httpClient.getresponse()
 #read result
 if response.status == HTTP_OK:
 #parse json into python primitive object
 result = response.read()
 else:
 result = response.read()
 if(path.find('.csv?')==-1):
 result=result.decode('utf-8').encode('GB18030')
 return response.status, result
 except Exception, e:
 #网络连接失败,关闭当前连接,再重新建立
 print i
 if self.httpClient is not None:
 self.httpClient.close()
 self.httpClient = httplib.HTTPSConnection(self.domain, self.port, timeout=60)
 return -1,'cannot connect '+str(self.reconnectTimes)+' times'