本文整理汇总了Python中tornado.escape.json_encode函数的典型用法代码示例。如果您正苦于以下问题：Python json_encode函数的具体用法？Python json_encode怎么用？Python json_encode使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了json_encode函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: get
def get(self):
word = self.get_argument('word')
word = word.encode('utf_8')
c = redis.Redis(host='127.0.0.1', port=6379, db=0)
tag = c.exists(word)
#c = database.AsyncRedis.client()
#tag = yield c.async.exists(word)
if tag:
#value = yield c.async.zrange("%s"%word, 0, -1, False)
value = c.zrange(word, 0, -1)
#c.zincrby(word, value, 1)
data = []
value = eval(value[0])
for li in value:
songname = li[2]
singer = li[3]
album = li[-1]
url = "commdown('" + "','".join(li) + "');"
result = {}
result['songname'] = songname
result['singer'] = singer
result['album'] = album
result['from'] = "kuwo"
result['url'] = url
data.append(result)
json = {"result":data}
self.write(json_encode(json))
#self.write(json_encode(json))
else:
self.write(json_encode(''))
开发者ID:GitHublong，项目名称:music_search，代码行数:32，代码来源:music.py
示例2: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.EVENT_ID not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.EVENT_ID] = int(params[KEY.EVENT_ID])
supporter_ids = db.list_support_relation(params)
print supporter_ids
if supporter_ids is not None:
supporter_info = []
for item in supporter_ids:
user_info = db.get_user_information({KEY.ID: item})
if user_info is not None:
user = {}
user[KEY.ID] = user_info[KEY.ID]
user[KEY.NICKNAME] = user_info[KEY.NICKNAME]
user[KEY.NAME] = user_info[KEY.NAME]
user[KEY.OCCUPATION] = user_info[KEY.OCCUPATION]
user[KEY.REPUTATION] = user_info[KEY.REPUTATION]
user[KEY.LOCATION] = user_info[KEY.LOCATION]
user[KEY.IS_VERIFY] = user_info[KEY.IS_VERIFY]
user[KEY.GENDER] = user_info[KEY.GENDER]
supporter_info.append(user)
resp[KEY.STATUS] = 200
resp[KEY.INFO] = supporter_info
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:31，代码来源:helper_list.py
示例3: post
def post(self):
user = self.current_user
result = {'kind':1, 'info':''}
follow_id = is_value(self.get_argument("id", None))
do = is_value(self.get_argument("do", 'follow'))
follow_type = is_value(self.get_argument("follow_type", 'author'))
if follow_id is None or do not in ['follow', 'unfollow'] or follow_id == str(user._id):
result['info'] = '参数错误！'
self.write(json_encode(result))
return
if follow_type != 'group':
try:
follower = User(_id=follow_id)
except Exception, e:
logging.error('User is not exist, in AuthorDoFollowHandler, user id: %s' % follow_id)
result['info'] = '该用户不存在！'
self.write(json_encode(result))
return
else:
if do == "follow":
user.follow_user(follower)
result['kind'] = 0
elif do == "unfollow":
user.unfollow_user(follower)
result['kind'] = 0
self.write(json_encode(result))
return
开发者ID:deju，项目名称:afw_old，代码行数:28，代码来源:AF_User.py
示例4: post
def post(self):
"""Add a facility."""
global compressed_facilities
if not revisit_online:
raise tornado.web.HTTPError(502)
new_facility = json_decode(self.request.body)
c_facilities_json = json_decode(compressed_facilities)
facility_data = (
c_facilities_json['facilities']['children']['wn']['data'][0]
)
uncompressed = json_decode(lzs.decompressFromUTF16(facility_data))
uncompressed.append({
'_version': 0,
'active': True,
'coordinates': new_facility['coordinates'],
'createdAt': '2014-04-23T20:32:20.043Z',
'href': (
'http://localhost:3000/api/v0/facilities/{}.json'.format(
new_facility['uuid']
)
),
'identifiers': [],
'name': new_facility['name'],
'properties': new_facility['properties'],
'updatedAt': '2014-04-23T20:32:20.043Z',
'uuid': new_facility['uuid'],
})
compressed = lzs.compressToUTF16(json_encode(uncompressed))
c_facilities_json['facilities']['children']['wn']['data'] = [
compressed
]
compressed_facilities = json_encode(c_facilities_json).encode()
self.set_status(201)
开发者ID:SEL-Columbia，项目名称:dokomoforms，代码行数:33，代码来源:debug.py
示例5: get
def get(self, *args):
url = self.get_argument('url')
response = yield fetch_webpage(url)
if response.body:
(bookmark, webpage) = self.bm.refresh_by_goose(url, html=response.body)
else:
print("Error:", response.error)
self.write(json_encode({'success': 'false'}))
# 默认使用readability的parser API
# 教程: http://www.readability.com/developers/api/parser
# try:
# http_client = tornado.httpclient.AsyncHTTPClient()
# response = yield http_client.fetch("https://readability.com/api/content/v1/parser?token=7f579fc61973e200632c9e43ff2639234817fbb3&url=" + tornado.escape.url_escape(url))
# if response.body:
# (bookmark, webpage) = self.bm.refresh_by_readability(url, readability=response.body)
# except tornado.httpclient.HTTPError:
# # print("Error:", response.error)
# # 备用，处理readability无法识别的网页
# response = yield fetch_webpage(url)
# if response.body:
# (bookmark, webpage) = self.bm.refresh_by_html(url, html=response.body)
# else:
# print("Error:", response.error)
# self.write(json_encode({'success': 'false'}))
if bookmark:
bookmark_module = tornado.escape.to_basestring(
self.render_string('modules/bookmark.html', bookmark=bookmark))
self.write(json_encode({
'success': 'true',
'bookmark_module': bookmark_module,
'title': bookmark['title'],
'article': tornado.escape.to_basestring(webpage['content'])
}))
else:
self.write(json_encode({'success': 'false'}))
开发者ID:ZoeyYoung，项目名称:Bookmarks_Cloud，代码行数:35，代码来源:bookmarks_handlers.py
示例6: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.LONGITUDE not in params or KEY.LATITUDE not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.LONGITUDE] = float(params[KEY.LONGITUDE])
params[KEY.LATITUDE] = float(params[KEY.LATITUDE])
params[KEY.STATE] = 0
event_id_list = db.get_nearby_event_by_location(params)
if event_id_list is not None:
event_list = []
for item in event_id_list:
event_info = db.get_event_information({KEY.EVENT_ID: item})
if event_info is not None:
event_temp = {}
event_temp[KEY.EVENT_ID] = event_info[KEY.EVENT_ID]
event_temp[KEY.TYPE] = event_info[KEY.TYPE]
event_temp[KEY.LONGITUDE] = event_info[KEY.LONGITUDE]
event_temp[KEY.LATITUDE] = event_info[KEY.LATITUDE]
event_list.append(event_temp)
resp[KEY.STATUS] = 200
resp[KEY.INFO] = event_list
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:28，代码来源:get_event_nearby.py
示例7: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.EVENT_ID not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.EVENT_ID] = int(params[KEY.EVENT_ID])
launcher_info = db.get_event_information(params)
if launcher_info is not None:
user_info = db.get_user_information({KEY.ID: launcher_info[KEY.LAUNCHER_ID]})
if user_info is not None:
resp[KEY.STATUS] = 200
resp[KEY.ID] = user_info[KEY.ID]
resp[KEY.NICKNAME] = user_info[KEY.NICKNAME]
resp[KEY.NAME] = user_info[KEY.NAME]
resp[KEY.AGE] = user_info[KEY.AGE]
resp[KEY.GENDER] = user_info[KEY.GENDER]
resp[KEY.PHONE] = user_info[KEY.PHONE]
resp[KEY.OCCUPATION] = user_info[KEY.OCCUPATION]
resp[KEY.REPUTATION] = user_info[KEY.REPUTATION]
resp[KEY.LOCATION] = user_info[KEY.LOCATION]
resp[KEY.IS_VERIFY] = user_info[KEY.IS_VERIFY]
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:27，代码来源:get_recipient_info.py
示例8: post
def post(self):
data = self.request.arguments
print data
timekey= data['timekey'][0]
s_file_path=data['s_file_path'][0]
filename=s_file_path.split('/')[-1]
copyinfo=None
if "salt://files/" not in s_file_path:
print "not in salt://"
if os.path.exists(s_file_path):
#如果filse目录不存在则创建
if not os.path.exists('/srv/salt/files'):
os.makedirs('/srv/salt/files')
#复制源文件到salt的files目录
shutil.copyfile(s_file_path,"/srv/salt/files/%s" %filename)
else:
print "no"
copyinfo= "%s is not exist" % s_file_path
print copyinfo
d_file_path=data['d_file_path'][0]
if not data['devsarr']:
ress={"status":1,"value":"no devs!"}
self.write(json_encode(ress))
#循环设备
for devid in data['devsarr']:
info = db.query('select * from host_devs where id='+devid)[0]
print info
ip = info['ip']
print "ip:"+ip
pushfiletask.delay(copyinfo, timekey, ip, filename, s_file_path, d_file_path)
ress={"status":0,"value":"提交任务成功"}
self.write(json_encode(ress))
开发者ID:cloudcache，项目名称:ops，代码行数:33，代码来源:ops.py
示例9: application_id
def application_id(self) -> ObjectId:
raw_application_id = self.handler.get_argument("application_id", None)
if raw_application_id is None:
self.handler.set_status(428, "missing param(s) application_id")
self.handler.finish(
json_encode(
{
"status": "error",
"message": "missing param(s) application_id"
}
)
)
raise Finish()
try:
return ObjectId(raw_application_id)
except InvalidId:
self.handler.set_status(412)
self.handler.finish(
json_encode(
{
"status": "error",
"message": "invalid param=application_id,application_id=%s" %
raw_application_id
}
)
)
raise Finish()
开发者ID:rdefeo，项目名称:api，代码行数:28，代码来源:extractors.py
示例10: post
async def post(self):
try:
args = RouteInputSchema().load(
escape.json_decode(self.request.body))
except ValidationError as e:
raise web.HTTPError(400, escape.json_encode(e.messages),
e.messages)
route_id = uuid.uuid4()
data = args.data
new_route = Route(
id=str(route_id),
origin=func.ST_GeomFromGeoJSON(escape.json_encode(data['origin'])),
origin_name=data['origin_name'],
destination=func.ST_GeomFromGeoJSON(
escape.json_encode(data['destination'])),
destination_name=data['destination_name'],
polyline=func.ST_GeomFromGeoJSON(escape.json_encode(data['polyline'])),
bounds=data.get('bounds'),
created=data.get('created') or datetime.utcnow()
)
self.db.add(new_route)
self.db.commit()
new_route_from_db = self._route_query().filter(
Route.id == str(route_id)).one()
schema = RouteOutputSchema()
output = schema.dumps(row_to_dict(new_route_from_db))
self.finish(output.data)
开发者ID:vovanbo，项目名称:route-builder-server，代码行数:28，代码来源:routes.py
示例11: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.ID not in params or KEY.LAUNCHER_ID not in params or KEY.TYPE not in params or KEY.EVENT_ID not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.EVENT_ID] = int(params[KEY.EVENT_ID])
params[KEY.ID] = int(params[KEY.ID])
params[KEY.LAUNCHER_ID] = int(params[KEY.LAUNCHER_ID])
params[KEY.TYPE] = int(params[KEY.TYPE])
flag = db.remove_support_relation(params)
if flag:
'''when the event is help or emergence, it is necessary to notify the users'''
user_info = db.get_user_information({KEY.ID: params[KEY.LAUNCHER_ID]})
user_info = utils.trans_unicode_to_utf(user_info)
if user_info is not None:
if params[KEY.TYPE] == 2:
mess = sendHelp.buildMessage(type=1, title=title, content=content, style=xinge.Style(0, 0, 0, 1, 3))
sendHelp.sendEhelp(header + user_info[KEY.NICKNAME], mess)
if params[KEY.TYPE] == 1:
mess = sendHelp.buildMessage(type=1, title=title, content=content, style=xinge.Style(0, 0, 0, 0, 6))
sendHelp.sendEhelp(header + user_info[KEY.NICKNAME], mess)
resp[KEY.STATUS] = 200
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:29，代码来源:cancel_support.py
示例12: get
def get(self, structure_id):
print "structure id", structure_id
if db[PDB_STR_COL_NAME].find_one({"structure_id": structure_id}) == None:
from crawler import download_pdb_file
pdb_str = download_pdb_file(structure_id)
if pdb_str is None:
#pdb id not found, return 500 code
self.set_status(500)
self.write(json_encode({
"pdb_id": structure_id,
"status":"not found"
}))
else:
#find one from pdb bank
db[PDB_STR_COL_NAME].insert({
"structure_id": structure_id,
"content": pdb_str
})
self.write(json_encode({
"pdb_id": structure_id,
"status":"inserted"
}))
else:
#it just exists in our db
self.write(json_encode({
"pdb_id": structure_id,
"status":"exist"
}))
开发者ID:xiaohan2012，项目名称:ve-web，代码行数:30，代码来源:select_pdb.py
示例13: sign_person_in
def sign_person_in(self, user):
"""
If we’ve seen the user before, update their info, otherwise create
a brand new user record and set their cookie.
"""
e_user = self.db.get("SELECT * FROM user WHERE twitter_id = %s", user['id'])
print "post here"
if e_user:
self.db.execute("""UPDATE user
SET name=%s, screen_name=%s, description=%s, location=%s, url=%s,
profile_image_url=%s, time_zone=%s, access_token=%s,
updated_at=NOW()
WHERE twitter_id = %s""", user['name'],
user['username'], user['description'], user['location'],
user['url'], user['profile_image_url'], user['time_zone'],
json_encode(user['access_token']),e_user['twitter_id'])
else:
self.db.execute("""INSERT INTO user (
twitter_id, name, screen_name, description, location, url,
profile_image_url, time_zone, access_token, created_at, updated_at)
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, NOW(), NOW())""",
user['id'], user['name'], user['username'], user['description'], user['location'],
user['url'], user['profile_image_url'], user['time_zone'],
json_encode(user['access_token']))
pid = {'id':user['id'], 'name':user['name'], 'username':user['username']}
self.set_secure_cookie("pid", tornado.escape.json_encode(pid), expires_days=365)
开发者ID:djacobs，项目名称:warmair，代码行数:28，代码来源:handlers.py
示例14: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.ID not in params or KEY.EVENT_ID not in params or KEY.LAUNCHER_ID not in params or KEY.TYPE not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.ID] = int(params[KEY.ID])
params[KEY.EVENT_ID] = int(params[KEY.EVENT_ID])
params[KEY.LAUNCHER_ID] = int(params[KEY.LAUNCHER_ID])
params[KEY.TYPE] = int(params[KEY.TYPE])
flag = db.add_support_relation(params)
if flag >= 0:
resp[KEY.STATUS] = 200
'''send notification to supportee, someone is coming to help him'''
launcher_info = db.get_user_information({KEY.ID: params[KEY.LAUNCHER_ID]})
launcher_info = utils.trans_unicode_to_utf(launcher_info)
if launcher_info is not None:
if params[KEY.TYPE] == 2:
mess = sendHelp.buildMessage(type=1, title=title, content=content, style=xinge.Style(0, 0, 0, 1, 2))
sendHelp.sendEhelp(header + launcher_info[KEY.NICKNAME], mess)
if params[KEY.TYPE] == 1:
mess = sendHelp.buildMessage(type=1, title=title, content=content, style=xinge.Style(0, 0, 0, 0, 5))
sendHelp.sendEhelp(header + launcher_info[KEY.NICKNAME], mess)
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:30，代码来源:give_support.py
示例15: post
def post(self):
user_id = int(self.get_argument('id', 0))
username = self.get_argument('username', '')
password = self.get_argument('password', '')
email = self.get_argument('email', '')
realname = self.get_argument('realname', '')
role_id = int(self.get_argument('role_id', 0))
match = re.search(r'[\w.-][email protected][\w.-]+', email)
if not match:
ret = {'code': 112, 'msg': self.error_message['112']}
return self.write(json_encode(ret))
if not role_id:
ret = {'code': 113, 'msg': self.error_message['113']}
return self.write(json_encode(ret))
result = User.update(user_id, username, email, password, realname, role_id)
if result:
ret = {'code': 0, 'msg': '更新成功'}
return self.write(json_encode(ret))
else:
ret = {'code': 114, 'msg': self.error_message['114']}
return self.write(json_encode(ret))
开发者ID:ListFranz，项目名称:PyCMS-Tornado，代码行数:25，代码来源:user.py
示例16: get_valid_locate_or_isp
def get_valid_locate_or_isp(self, kind = None):
"""
获取当前可用地区列表
从locate_mgr获取可用地区列表
查询RegisteredLocate，获取详细信息
{ "info" : { "data" : { "region_id" : "310000", "region" : "上海市", "isp" : "电信", "isp_id" : "100017" } } }
"""
if kind in ('region', 'isp'):
valid_locate = self.loct_mgr.get_valid_locate()
if valid_locate:
try:
cursor = self.mdb['RegisteredSlave'].find({'locate_key': {'$in': valid_locate}},
{'_id' : 0,
'ip_info.data.' + kind : 1,
'ip_info.data.' + kind +'_id': 1 })
except TypeError:
return self.write(json_encode({'code': 1, 'data': '数据库查询参数错误'}))
retval = []
tmp = {}
for res in cursor:
tmp.setdefault(res['ip_info']['data'][kind], res['ip_info']['data'][kind + '_id'])
for locate_name, locate_key in tmp.iteritems():
retval.append({locate_name: locate_key})
self.write(json_encode({'code': 0, 'data': retval}))
else:
self.write(json_encode({'code': 1, 'data': '当前没有信息'}))
else:
raise AssertionError('kind参数只能取值region或isp')
开发者ID:askdaddy，项目名称:monitor，代码行数:28，代码来源:base.py
示例17: post
def post(self):
try:
request = json_decode(self.request.body)
req_type = ""
if "type" in request.keys():
req_type = request["type"]
if not req_type:
self.write_error(406)
return
if req_type == "wiki":
wiki_link = ""
if "link" in request.keys():
wiki_link = request["link"]
if not core.utils.internet.internet.is_valid_url(wiki_link) or \
not wiki_link.startswith("https://en.wikipedia.org/wiki/"):
self.write_error(400)
return
all_links = wikilm.WikiLinkMaker.make_links_from_link(wiki_link)
self.set_header("Content-Type", "application/json")
self.write(json_encode(all_links))
else:
self.set_header("Content-Type", "application/json")
self.write(json_encode("Oops!"))
except Exception as e:
self.set_header("Content-Type", "application/json")
self.write("Error: " + json_encode(str(e)))
开发者ID:testlnord，项目名称:trends，代码行数:31，代码来源:tech_edit_handlers.py
示例18: post
def post(self):
category_id = int(self.get_argument('category_id', 0))
title = self.get_argument('title', '')
content = self.get_argument('content', '')
create_uid = self.get_secure_cookie('admin_user_id')
status = int(self.get_argument('status', 0))
if not category_id:
response = {'code': 110, 'msg': self.error_message['110']}
return self.write(json_encode(response))
if not title:
response = {'code': 111, 'msg': self.error_message['111']}
return self.write(json_encode(response))
if not content:
response = {'code': 112, 'msg': self.error_message['112']}
return self.write(json_encode(response))
result = News.new(category_id, title, content, create_uid, status)
if result:
response = {'code': 0, 'msg': '添加成功'}
return self.write(json_encode(response))
else:
response = {'code': 114, 'msg': self.error_message['114']}
return self.write(json_encode(response))
开发者ID:ListFranz，项目名称:PyCMS-Tornado，代码行数:25，代码来源:news.py
示例19: post
def post(self):
params = {}
resp = {KEY.STATUS: 500}
params = utils.decode_params(self.request)
if KEY.EVENT_ID not in params:
self.write(json_encode(resp))
return
'''trans the term's type'''
params[KEY.EVENT_ID] = int(params[KEY.EVENT_ID])
event_info = db.get_event_information(params)
if event_info is not None:
resp[KEY.STATUS] = 200
resp[KEY.LAUNCHER_ID] = event_info[KEY.LAUNCHER_ID]
resp[KEY.TIME] = event_info[KEY.TIME]
resp[KEY.TYPE] = int(event_info[KEY.TYPE])
resp[KEY.SUPPORT_NUMBER] = event_info[KEY.SUPPORT_NUMBER]
resp[KEY.DEMAND_NUMBER] = event_info[KEY.DEMAND_NUMBER]
resp[KEY.LONGITUDE] = event_info[KEY.LONGITUDE]
resp[KEY.LATITUDE] = event_info[KEY.LATITUDE]
resp[KEY.LAUNCHER_NAME] = event_info[KEY.LAUNCHER]
user = db.get_user_information({KEY.ID: resp[KEY.LAUNCHER_ID]})
if user is not None:
resp[KEY.CONTACT] = user[KEY.PHONE]
'''if this event is help'''
if resp[KEY.TYPE] == 1:
resp[KEY.TITLE] = event_info[KEY.TITLE]
resp[KEY.CONTENT] = event_info[KEY.CONTENT]
resp[KEY.LOVE_COIN] = int(event_info[KEY.LOVE_COIN])
self.write(json_encode(resp))
开发者ID:EHelp，项目名称:2015-2016-Project，代码行数:32，代码来源:list_event_detail.py
示例20: get
def get(self, user_id):
try:
user_id = user_id.replace('.json', '')
news_feed = []
for row in self.db_stories.view('stories/by_user_id', key=user_id, include_docs="true", descending="true", limit=10):
story = row.doc
story['story_id'] = story['_id']
del story['_id']
del story['_rev']
del story['session_id']
if 'media_name' not in story:
m = re.match('https\:\/\/.+amazonaws\.com\/(.+)\/(.+)', story['media_url'])
if m is not None:
story['media_bucket'] = m.group(1)
story['media_name'] = m.group(2)
news_feed.append(story)
self.write(json_encode({"news_feed":{
"response": "true",
"status": "success",
"news_feed": news_feed,
}}))
except Exception:
self.write(json_encode({"news_feed":{
"response": "false",
"status": "internal error",
"traceback": traceback.format_exc()
}}))
开发者ID:OpenFilter，项目名称:MediaManagerService，代码行数:27，代码来源:NewsFeedHandler.py
注：本文中的tornado.escape.json_encode函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论