#!/usr/bin/env python
# -*- coding: utf-8 -*-
import json
import riak
import memcache

from utils import pandas_to_dict

from pandas import DataFrame
from sqlalchemy import create_engine


mc = memcache.Client(['127.0.0.1:11211'], debug=0)
mc.delete('testando')
mc.delete('testando-columns')

myClient = riak.RiakClient(protocol='http', http_port=8098, host='127.0.0.1')
myBucket = myClient.bucket('openmining')

c = 'mysql://root:123mudar@192.168.12.4/upessencia_dev1'
e = create_engine('mysql://root:123mudar@192.168.12.4/upessencia_dev1')
connection = e.connect()

sql = """SELECT 
cliente.id_cliente,
cliente.nome,
pedido.id_pedido,
pedido.criacao_ts as 'pedido_data',
cliente.criacao_ts as 'cliente_data' 
FROM pedido 
inner join cliente on cliente.id_cliente = pedido.id_cliente 
WHERE pedido.id_pedido_status NOT IN (4,8,9) 
AND pedido.entrega_forma<>'franquia' limit 100"""

resoverall = connection.execute(sql)

df = DataFrame(resoverall.fetchall())
df.columns = resoverall.keys()
df.head()

convert = pandas_to_dict(df)

join = json.dumps(convert)
b1 = myBucket.new('testando', data=join)
b1.store()

b2 = myBucket.new('testando-columns', data=json.dumps([c for c in df.columns]))
b2.store()

b3 = myBucket.new('testando-connect', data=c)
b3.store()

b4 = myBucket.new('testando-sql', data=sql)
b4.store()

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import json
import riak
import memcache

from pandas import DataFrame
from sqlalchemy import create_engine

from utils import pandas_to_dict

mc = memcache.Client(['127.0.0.1:11211'], debug=0)
mc.delete('testando')
mc.delete('testando-columns')

myClient = riak.RiakClient(protocol='http', http_port=8098, host='127.0.0.1')
myBucket = myClient.bucket('openmining')

c = 'mysql://root:123mudar@192.168.12.4/upessencia_dev1'
e = create_engine('mysql://root:123mudar@192.168.12.4/upessencia_dev1')
connection = e.connect()

sql = """SELECT
cliente.id_cliente,
cliente.nome,
pedido.id_pedido,
pedido.criacao_ts as 'pedido_data',
cliente.criacao_ts as 'cliente_data'
FROM pedido
inner join cliente on cliente.id_cliente = pedido.id_cliente
WHERE pedido.id_pedido_status NOT IN (4,8,9)
AND pedido.entrega_forma<>'franquia' limit 100"""

resoverall = connection.execute(sql)

df = DataFrame(resoverall.fetchall())
df.columns = resoverall.keys()
df.head()

convert = pandas_to_dict(df)

join = json.dumps(convert)
b1 = myBucket.new('testando', data=join)
b1.store()

b2 = myBucket.new('testando-columns', data=json.dumps([c for c in df.columns]))
b2.store()

b3 = myBucket.new('testando-connect', data=c)
b3.store()

b4 = myBucket.new('testando-sql', data=sql)
b4.store()

Fix pep8 on bin file