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.3.0.tar.gz
(9.1 kB
view hashes)
Built Distribution
Close
Hashes for druid_query-0.3.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 154533bb4934138fa9b5c45d4ccf35ecba56c24e6ce2a6b7716dc562d3c616bb |
|
MD5 | 06196938829f174edf0c2074cdc6b257 |
|
BLAKE2b-256 | d2f56db4c0f6a80b9c26eefa9739fba6e650240a21e8408630cb6b47d363f299 |