Hello everyone, I'm trying to launch a task through the prefect with a call to clickhouse, I did not find the library of the prefect's tasks. Can anyone who has done a similar task, please share the solution, thanks
from clickhouse_driver import Client, dbapi
client = Client(Host_name,
port=Host_port,
user=User_db,
password=Pass_db,
secure=False,
verify=False,
database=DB_name,
compression=True)
result = client.execute('SELECT now(), version()')
Konstantin
02/22/2022, 9:51 AM
what could be wrong?
a
Anna Geller
02/22/2022, 10:19 AM
We don't have a Clickhouse task integration yet, but if you want to contribute, check out this guide and we are happy to review your PR.
Also, for Clickhouse questions, they also have a Slack channel, maybe you can ask there https://clickhousedb.slack.com/
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.