x/stackalytics
Code Issues Proposed changes

Encode user_id and email before dumping them

Browse Source 
Change-Id: Icce8dce6477bfce28854484185d5303eff2888be
This commit is contained in:
Ilya Shakhat
2015-04-16 16:47:52 +03:00
parent 4c2a3bccd1
commit 99e8407ce6
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
stackalytics/processor/dump.py
View File

@@ -131,7 +131,8 @@ def export_data(memcached_inst, fd):
user = memcached_inst.get('user:%s' % user_seq) user = memcached_inst.get('user:%s' % user_seq)
if user: if user:
if user.get('user_id'): if user.get('user_id'):
pickle.dump(('user:%s' % user['user_id'], user), fd) pickle.dump((('user:%s' % user['user_id']).encode('utf8'),
user), fd)
if user.get('launchpad_id'): if user.get('launchpad_id'):
pickle.dump(('user:%s' % user['launchpad_id'], user), fd) pickle.dump(('user:%s' % user['launchpad_id'], user), fd)
if user.get('gerrit_id'): if user.get('gerrit_id'):
@@ -139,7 +140,7 @@ def export_data(memcached_inst, fd):
if user.get('member_id'): if user.get('member_id'):
pickle.dump(('user:member:%s' % user['member_id'], user), fd) pickle.dump(('user:member:%s' % user['member_id'], user), fd)
for email in user.get('emails') or []: for email in user.get('emails') or []:
pickle.dump(('user:%s' % email, user), fd) pickle.dump((('user:%s' % email).encode('utf8'), user), fd)
def _connect_to_memcached(uri): def _connect_to_memcached(uri):