Its good to use to use python druid
for line in lines:
producer.send('vtintel', value=line)
sleep(1)
I can fetch data through kafka consumer but not in pydruid in python.
When I try to do so like
from pydruid.db import connect
conn = connect(host='localhost', port=8082, path='/druid/v2/sql/',
scheme='http')
curs = conn.cursor()
curs.execute("""
SELECT detected,domain
FROM vtintel
LIMIT 10
""")
for row in curs:
print(row)
for line in lines:
producer.send('vtintel', value=line)
sleep(1)
I can fetch data through kafka consumer but not in pydruid in python.
When I try to do so like
from pydruid.db import connect
conn = connect(host='localhost', port=8082, path='/druid/v2/sql/',
scheme='http')
curs = conn.cursor()
curs.execute("""
SELECT detected,domain
FROM vtintel
LIMIT 10
""")
for row in curs:
print(row)