diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/process_queue.py | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 02752d03..5f96345b 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -7,13 +7,11 @@ if sys.version_info.major == 3: else: from cStringIO import StringIO -# from io import BytesIO, StringIO import datetime from pickle import loads from ftplib import FTP import config import os -import sys def decode_dict(d): return {k.decode() if isinstance(k, bytes) else k: \ @@ -22,8 +20,7 @@ def decode_dict(d): def get_trades(): q = redis.Redis(host = 'debian') p = q.pipeline() - p.lrange('trades', 0, -1) - #.delete('trades') + p.lrange('trades', 0, -1).delete('trades') r = p.execute() if sys.version_info.major == 3: df = pd.DataFrame([decode_dict(loads(e, encoding='bytes')) for e in r[0]]) @@ -94,4 +91,4 @@ if __name__=="__main__": buf = generate_csv(df) if buf: timestamp = write_buffer(buf) - #upload_file(timestamp) + upload_file(timestamp) |