Apache Druid querying client library
Project description
Apache Druid Query Library
A simple library for creating and executing queries with Apache Druid.
Usage
SQL Queries
from druid_query.client import Client
from druid_query.queries import Sql
client = Client(sql_endpoint='localhost:8082/druid/v2/sql/')
query = Sql('SELECT * FROM wikipedia LIMIT 10')
result = client.execute(query)
print(result)
Native Queries
from druid_query.client import Client
from druid_query.components import *
from druid_query.queries import Timeseries
client = Client(native_endpoint='localhost:8082/druid/v2/')
query = Timeseries('wikipedia', [intervals.Interval('2015-09-11', '2015-09-13')], granularities.Period('PT2H'), aggregations=[aggregations.Count('num_records')])
result = client.execute(client, query)
print(result)
Async support
from druid_query.client import AsyncClient
from druid_query.queries import Sql
import asyncio
client = AsyncClient(sql_endpoint='localhost:8082/druid/v2/sql/')
query = Sql('SELECT * FROM wikipedia LIMIT 10')
result = asyncio.run(client.execute(query))
print(result)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
druid_query-0.2.0.tar.gz
(9.0 kB
view hashes)
Built Distribution
Close
Hashes for druid_query-0.2.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | fe9ab28230ce0f92a76096d1b71642069731b25acfcbab7453a0f4205b3938ab |
|
MD5 | 3215eb98345596b2396324a664f84841 |
|
BLAKE2b-256 | 5b6897f0ac3739403d98f9748fa29fcee51071cb7098b5febdfe9699151ab1af |