Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import psycopg2
- query = """
- SELECT seq, modify, bid, rate, amount, date FROM books
- WHERE market='%s'
- ORDER BY seq ASC OFFSET %d LIMIT %d
- """
- host = "url"
- database = "ticks"
- username = "postgres"
- password = ""
- prod_conn = psycopg2.connect("host='%s' dbname='%s' user='%s' password='%s'" % (
- host, database, username, password))
- host = "localhost"
- database = "ticks"
- username = "postgres"
- password = ""
- local_conn = psycopg2.connect("host='%s' dbname='%s' user='%s' password='%s'" % (
- host, database, username, password))
- local_cur = local_conn.cursor()
- prod_cur = prod_conn.cursor()
- MARKET = 'BTC_ETH'
- BATCH_SIZE = 1000
- while True:
- offset = 0
- prod_cur.execute(queryBooks % (MARKET, offset, BATCH_SIZE))
- for row in cur.fetchall():
- offset += 1
- print row
- # ...
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement