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.1.tar.gz
(9.1 kB
view hashes)
Built Distribution
Close
Hashes for druid_query-0.2.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d2cc4bcad9b1d81ff0bee9f2172f6e3690bf2f5bd71eea832113d743b0a86c08 |
|
MD5 | 083f0f3b9937c302ccaf6f1f14add72c |
|
BLAKE2b-256 | a97ec4f461a15356135310ffe89f5c78c621dc4243872651e545188ae3fa6e01 |