Как получить данные от друида, который принимает данные через кафку в python? - PullRequest
Новая
       29

Как получить данные от друида, который принимает данные через кафку в python?

1 голос
/ 02 мая 2019

Я создал схему данных для druid. Затем я включил использование druid kafka с помощью этой команды 

curl -XPOST -H'Content-Type: application/json' -d @quickstart/tutorial/my_schema.json http://localhost:8081/druid/indexer/v1/supervisor

, пока все хорошо.Затем в python я сделал скрипт производителя kafka 

        for line in lines:

            producer.send('vtintel', value=line)
            sleep(1)

Я могу получать данные через kafka customer, но не в pydruid в python.

Когда я пытаюсь сделать это, как 

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)

Я получаю ошибку: 

pydruid.db.exceptions.ProgrammingError: Unknown error (Unknown):
...