本文整理汇总了Python中yajl.dumps函数的典型用法代码示例。如果您正苦于以下问题:Python dumps函数的具体用法?Python dumps怎么用?Python dumps使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了dumps函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: post
def post(self,game_session):
self.game_session=game_session
game=sessions[game_session]
uid=self.get_secure_cookie("uid")
try:
index=json.loads(self.get_argument("i",None))
except:
self.finish()
return
if(not index):
if(not game["users"][uid]):
game["user_connections"][uid]=self
return
self.finish({"updates":game["users"][uid]+["reconnect"]})
game["users"][uid]=[]
return
if(game["current_uid"]!=uid): #ok update game state and send the status update for the other user and keep this user in wait mode
if(game["state"][index[0]][index[1]]!=False):
self.finish({"updates":["your move"]})
return
game["state"][index[0]][index[1]]=uid
uid_other=game["current_uid"]
game["user_connections"][uid]=self
game["current_uid"]=uid
try:
game["user_connections"][uid_other].finish({'updates':["update "+json.dumps(index),"your move"]})
except:
game["users"][uid_other]+=["update "+json.dumps(index),"your move"]
self.finish({"updates":["wait","reconnect"]})
return
self.finish({"updates":["wait"]})
开发者ID:abhinavabcd,项目名称:ultimate_tictactoe,代码行数:32,代码来源:tic_old_rm.py
示例2: magpie_to_json
def magpie_to_json(self, var):
"""
One-time use. For converting MAgPIE nc4 to json.
"""
# for crop in ['bmg', 'bmt', 'cas', 'mai', 'mgr', 'mil', 'nut', 'oth', 'pea', 'rap', 'ric', 'sgb', 'soy', 'sug', 'sun', 'whe']:
for crop in ['whe',]:
d = netCDF4.Dataset(os.path.join(
'..', 'data', 'netcdf', 'magpie',
'MAgPIE_LUC_for_ATLAS_illustration_{}_agg.nc4'.format(crop)
))
# for irr in ['firr', 'rainf']:
# d = netCDF4.Dataset(os.path.join('..', 'data', 'netcdf', 'magpie', 'MAgPIE_LUC_for_ATLAS_illustration_{}_{}.nc4'.format(crop, irr)))
_v = d.variables['{}_gadm{}'.format(crop, self._adm)][:]
_gi = d.variables['gadm{}_index'.format(self._adm)][:]
new_data = {}
for i in range(len(_gi)):
new_data[str(_gi[i])] = [v - np.mean(_v[:20]) for v in _v[i].tolist()[20:]]
with open('../static/json/aggr/gadm{}/magpie/{}_gadm{}.json'.format(
self._adm, crop, self._adm), 'w') as f:
f.write(
json.dumps(
{
'data': new_data,
'min': round(np.min(_v[:]), 1),
'max': round(np.max(_v[:]), 1),
}
)
)
trimmed = {
'data': {k: np.array(v)[:, 0].tolist() for k, v in new_data.iteritems()},
'min': round(np.min([np.array(v)[:, 0].tolist() for k, v in new_data.iteritems()]), 1),
'max': round(np.max([np.array(v)[:, 0].tolist() for k, v in new_data.iteritems()]), 1),
}
with open('../static/json/aggr/gadm{}/magpie/{}_gadm{}_home.json'.format(self._adm, crop, self._adm), 'w') as f:
f.write(json.dumps(trimmed))
开发者ID:ricardobarroslourenco,项目名称:atlas-viewer,代码行数:35,代码来源:data_munger.py
示例3: runTest
def runTest(self):
normal = {'a' : 'b', 'c' : 'd'}
self.assertEquals(yajl.dumps(normal), '{"a":"b","c":"d"}')
if not is_python3():
from tests import python2
self.assertEquals(yajl.dumps(python2.IssueTwelveTest_dict), '{"a":"b","c":"d"}')
开发者ID:dtjm,项目名称:py-yajl,代码行数:7,代码来源:unit.py
示例4: api
def api(self, **kwargs):
self.content_type = 'text/plain'
return '{}'
if kwargs.get('encode'):
return json.dumps(self.encode_json(**kwargs))
if kwargs.get('decode'):
return json.dumps(self.decode_json(**kwargs))
return '{}'
开发者ID:pombredanne,项目名称:urlenco.de,代码行数:8,代码来源:api.py
示例5: report_result
def report_result(item):
try:
item_json = json.dumps(item)
except UnicodeDecodeError:
item['result'] = "FIXME: unicode decode error"
item.pop('content')
try:
item_json = json.dumps(item)
except UnicodeDecodeError:
log.error("Fatal unicode decode error @ %s", item['url'])
return
request_manager('/report', 'PUT', item_json)
开发者ID:GunioRobot,项目名称:heroshi,代码行数:12,代码来源:api.py
示例6: insert
def insert(title, tags, content, author, rating, url, reply_list, pic_list):
key = url_key_builder(url)
if not Spider.get(url_hash=key):
entry = Spider()
entry.title = title
entry.tags = dumps(tags)
entry.content = content
entry.author = author
entry.rating = rating
entry.url_hash = key
entry.url = url
entry.url_hash = key
entry.reply_list = dumps(reply_list)
entry.pic_list = dumps(pic_list)
entry.save()
开发者ID:immissile,项目名称:42qu_github_mirror,代码行数:15,代码来源:writer.py
示例7: collect
def collect(self, port):
while True:
req = port.read()
if not req:
break
if req == "?":
self.ggroup.map(self.pingall, self.telescreens.iterkeys())
port.write(json.dumps(self.telescreens.keys()))
continue
if req == "*":
want_list = self.telescreens.iterkeys()
else:
want_list = json.loads(req)
rep = self.ggroup.map(self.fetch_state, want_list)
port.write(json.dumps({k: v for k, v in rep if v}))
开发者ID:Tefx,项目名称:Thinkpol,代码行数:15,代码来源:miniture.py
示例8: _call
def _call(self, func_name, o):
if func_name.startswith("_") or func_name in self.DISABLED:
raise HTTPError(400)
func = getattr(self,func_name, None)
if func is None:
raise HTTPError(501)
if o is not None:
o = loads(o)
type_o = type(o)
if type_o is list:
r = func(*o)
elif type_o is dict:
r = func(**o)
else:
r = func(o)
else:
r = func()
if r is None:
chunk = '{}'
elif isinstance(r, Err) and r:
chunk = '{"err":%s}'%str(r)
elif isinstance(r, JsOb):
chunk = str(r)
else:
chunk = dumps(r)
return chunk
开发者ID:PegasusWang,项目名称:collection_python,代码行数:30,代码来源:__init__.py
示例9: add_gadm1_codes_to_ne1_json
def add_gadm1_codes_to_ne1_json(self):
"""
Add GADM level 1 information to level 1 map outlines from Natural Earth.
"""
gadm = pd.DataFrame.from_csv('./gadm1.meta.csv', index_col=4)
gadm.index = np.arange(len(gadm))
with open('../static/topojson/ne1_s0001.json') as f:
ne = json.loads(f.read())
for region in ne['objects']['regions']['geometries']:
props = region['properties']
try:
country = pycountry.countries.get(alpha2=props['iso_a2'])
region['properties']['iso'] = country.alpha3
id0 = gadm.ix[gadm['ISO'] == country.alpha3].\
ix[gadm['NAME'] == props['name'].encode('latin_1')].ID_0.values[0]
id1 = gadm.ix[gadm['ISO'] == country.alpha3].\
ix[gadm['NAME'] == props['name'].encode('latin_1')].ID_1.values[0]
region['properties']['adm1'] = '{0:02d}'.format(id1)
region['properties']['adm0'] = '{0}'.format(id0)
region['properties']['adm'] = '{0}{1:02d}'.format(id0, id1)
except:
pass
with open('../static/topojson/atlas_gadm1.json', 'w') as f:
f.write(json.dumps(ne))
return ne
开发者ID:ricardobarroslourenco,项目名称:atlas-viewer,代码行数:25,代码来源:data_munger.py
示例10: server
def server(request):
handler_map = urls.get(request.path)
if not handler_map:
# default behaviour is 404 to all unknown URLs
raise webob.exc.HTTPNotFound()
auth_error = check_auth(request)
if auth_error:
log.info("auth: " + auth_error)
raise webob.exc.HTTPUnauthorized(auth_error)
with manager_pool.item() as manager:
handler = method_dispatcher(**dict( (method, getattr(manager, name))
for method,name in handler_map.iteritems() ))
result = handler(request)
response = Response(json.dumps(result), content_type='application/json')
if not response.etag and (200 <= response.status_int < 300):
# generate Etag from URL and response.body
sha256_tag = hashlib.sha256(request.path + response.body).digest()
response.etag = b64encode(sha256_tag)
if 'gzip' in request.accept_encoding and len(response.body) > MIN_COMPRESS_LENGTH:
# client supports gzipped answer and response is reasonably long for compression benefits
response.content_encoding = 'gzip'
response.body = gzip_string(response.body)
return response
开发者ID:GunioRobot,项目名称:heroshi,代码行数:26,代码来源:server.py
示例11: DeleteAllDatasetsFromOrg
def DeleteAllDatasetsFromOrg(organization, hdx_site, apikey, verbose=True):
'''Delete all datasets owned by an organization.'''
if verbose:
print "--------------------------------------------------"
print "//////////////////////////////////////////////////"
print "--------------------------------------------------"
print "////////////// DELETING DATASETS /////////////////"
print "--------------------------------------------------"
print "//////////////////////////////////////////////////"
print "--------------------------------------------------"
# Checking for input.
if (organization is None):
print "No organization id provided. Please provide an organization id."
print "--------------------------------------------------"
return False
# Base config.
organization_show_url = hdx_site + '/api/action/organization_show?id='
package_delete_url = hdx_site + '/api/action/package_delete'
headers = { 'X-CKAN-API-Key': apikey, 'content-type': 'application/json' }
# Fetching dataset information.
dataset_dict = requests.get(organization_show_url + organization, headers=headers, auth=('dataproject', 'humdata')).json()
#
# Progress bar.
#
i = 0
widgets = [I('prompt_bullet'), ' Deleting resources:', pb.Percentage(), ' ', pb.Bar('-'), ' ', pb.ETA(), ' ']
pbar = pb.ProgressBar(widgets=widgets, maxval=len(dataset_dict)).start()
#
# Iterating over every dataset.
#
if dataset_dict["success"] is True:
pbar.update(i)
for dataset in dataset_dict["result"]["packages"]:
u = { 'id': dataset["id"] }
r = requests.post(package_delete_url, data=json.dumps(u), headers=headers, auth=('dataproject', 'humdata'))
if r.status_code != 200:
print "%s : %s" % (I('prompt_error'), dataset["name"])
else:
print "%s : %s" % (I('prompt_success'), dataset["name"])
i += 1
else:
print "%s There was an error getting the dataset list." % I('prompt_error')
print "--------------------------------------------------"
return False
开发者ID:luiscape,项目名称:hdxscraper-noaa,代码行数:60,代码来源:delete.py
示例12: fetch
def fetch(self, want="*"):
if want == "*":
req = "*"
else:
req = json.dumps(want)
self.port.write(req)
return json.loads(self.port.read())
开发者ID:Tefx,项目名称:Thinkpol,代码行数:7,代码来源:agent.py
示例13: get
def get(self, id):
# data = {
# "zsite":{
# "name":"w",
# "unit":"xx",
# "title":"zz"
# },
# "name":"2011年第2次BPUG活动",
# "id":1234,
# "fav":True,
# "reply_count":1,
# "tag_id":232,
# "tag_name":"sss"
# }
po = Po.mc_get(id)
user = po.user
result = [id]
result.extend(feed_tuple_by_db(id))
result.pop()
result.pop()
result.append(po.htm)
zsite = [user.name, user.link]
zsite.extend(career_current(po.user_id))
result.append(zsite)
self.finish(dumps(result))
开发者ID:immissile,项目名称:42qu_github_mirror,代码行数:27,代码来源:po.py
示例14: post
def post(self):
result = None
current_user_id = self.current_user_id
txt = self.get_argument('txt', None)
if txt:
host = self.request.host
zsite = zsite_by_domain(host)
if zsite and zsite.cid == CID_SITE:
zsite_id = zsite.id
else:
zsite_id = 0
m = po_word_new(current_user_id, txt, zsite_id=zsite_id)
if not zsite_id and m:
c_dict = career_dict(set([current_user_id]))
unit, title = c_dict[current_user_id]
result = [
[
1, zsite.name, zsite.link, unit,
title, pic_url_with_default(current_user_id, '219'),
[[m.id, [], 0, 61, 0, 0, 0, time.time(), None, txt_withlink(txt), False]]
],
[]
]
self.finish(dumps(result))
开发者ID:immissile,项目名称:42qu_github_mirror,代码行数:25,代码来源:po.py
示例15: charged
def charged(out_trade_no, total_fee, rid, d):
id, vid, ck = out_trade_no.split('_', 2)
user_id, vcid = verifyed(vid, ck)
if vcid == CID_VERIFY_MONEY:
t = Trade.get(id)
if t and t.to_id == user_id and t.rid == rid and t.value + t.tax == int(float(total_fee)*100):
if t.state == TRADE_STATE_ONWAY:
trade_finish(t)
trade_log.set(id, dumps(d))
for_t = Trade.get(t.for_id)
if for_t:
if bank_can_pay(for_t.from_id, for_t.value):
for_cid = for_t.cid
if for_cid == CID_TRADE_PAY:
trade_finish(for_t)
pay_notice(for_t.id)
elif for_cid == CID_TRADE_EVENT:
from event import event_joiner_state, event_joiner_new, EVENT_JOIN_STATE_NEW
event_id = for_t.rid
user_id = for_t.from_id
if event_joiner_state(event_id, user_id) < EVENT_JOIN_STATE_NEW:
trade_open(for_t)
event_joiner_new(event_id, user_id)
else:
trade_fail(for_t)
return t
return for_t
return t
开发者ID:yupbank,项目名称:taobaosdk,代码行数:28,代码来源:model_money.py
示例16: testLong
def testLong(self):
''' http://github.com/rtyler/py-yajl/issues#issue/10 '''
if is_python3():
return
data = {long(1) : 2}
result = yajl.loads(yajl.dumps(data))
self.assertEquals({'1': 2}, result)
开发者ID:dtjm,项目名称:py-yajl,代码行数:7,代码来源:unit.py
示例17: _handle
def _handle(self, environ, start_response):
segments = filter(None, environ['PATH_INFO'].split('/'))
params = cgi.parse_qs(
environ.get('QUERY_STRING', ''), keep_blank_values=True)
roomname = segments[0]
username = environ['auth'][0]
yak = client.Yakity(self._config, self._junction_client, username)
if len(segments) == 1:
if environ['REQUEST_METHOD'] == 'GET':
last_seen = int(self._get_param('last', params) or 0)
result = yak.read(roomname, last_seen)
for r in result:
r['timestamp'] = time.ctime(r['timestamp'] + timediff)
return json.dumps(result)
if environ['REQUEST_METHOD'] == 'POST':
msg = environ['wsgi.input'].read()
yak.say(roomname, msg)
return '{"success":true}'
if segments[1] == 'join':
yak.join(roomname)
return '{"success":true}'
if segments[1] == 'depart':
yak.depart(roomname)
return '{"success":true}'
开发者ID:teepark,项目名称:yakity,代码行数:30,代码来源:wsgi_api.py
示例18: add_gadm1_codes_to_gadm1_json
def add_gadm1_codes_to_gadm1_json(self):
"""
Add GADM level 1 information to level 1 map outlines from GADM.
"""
with open('../static/topojson/gadm1_map.json') as f:
ga = json.loads(f.read())
ga['objects']['regions'] = ga['objects']['_bejeezus']
ga['objects'].pop('_bejeezus', None)
for region in ga['objects']['regions']['geometries']:
props = region['properties']
try:
region['properties']['iso'] = region['properties']['ISO']
region['properties']['adm1'] = '{0:02d}'.format(region['properties']['ID_1'])
region['properties']['adm0'] = '{0}'.format(region['properties']['ID_0'])
region['properties']['adm'] = '{0}{1:02d}'.format(region['properties']['ID_0'], region['properties']['ID_1'])
region['properties']['name'] = region['properties']['NAME_1']
region['properties']['country'] = region['properties']['NAME']
region['properties'].pop('ISO', None)
region['properties'].pop('ID_1', None)
region['properties'].pop('ID_0', None)
region['properties'].pop('ENGTYPE_1', None)
region['properties'].pop('TYPE_1', None)
region['properties'].pop('NL_NAME_1', None)
region['properties'].pop('VARNAME_1', None)
except:
pass
with open('../static/topojson/atlas_gadm1.json', 'w') as f:
f.write(json.dumps(ga))
return ga
开发者ID:ricardobarroslourenco,项目名称:atlas-viewer,代码行数:29,代码来源:data_munger.py
示例19: test_chinese
def test_chinese(self):
''' Testing with simplified chinese for http://github.com/rtyler/py-yajl/issues/#issue/7 '''
char = '\u65e9\u5b89, \u7238\u7238'
if not is_python3():
from tests import python2
char = python2.IssueSevenTest_chinese_char
out = yajl.dumps(char).lower()
self.assertEquals(out, '"\\u65e9\\u5b89, \\u7238\\u7238"')
out = yajl.dumps(out).lower()
self.assertEquals(out, '"\\"\\\\u65e9\\\\u5b89, \\\\u7238\\\\u7238\\""')
out = yajl.loads(out)
self.assertEquals(out, '"\\u65e9\\u5b89, \\u7238\\u7238"')
out = yajl.loads(out)
self.assertEquals(out, char)
开发者ID:dtjm,项目名称:py-yajl,代码行数:17,代码来源:unit.py
示例20: get
def get(self):
q = self.get_argument('q',None)
if q:
result = dumps((int(i[0]),int(i[1]),escape(i[2])) for i in autocomplete_tag.id_rank_name_list_by_str(q))
else:
result = []
self.finish(jsonp(self,result))
开发者ID:immissile,项目名称:42qu_github_mirror,代码行数:8,代码来源:tag.py
注:本文中的yajl.dumps函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论