Install

pip install verdin

Requirements

Usage

Run an SQL Query

# the tinybird module exposes all important tinybird conceptsfromverdinimporttinybirdclient=tinybird.Client("p.mytoken")query=client.sql("select * from my_datasource__v0")# run the query with `FORMAT JSON` and receive a QueryJsonResultresponse:tinybird.QueryJsonResult=query.json()# print records returned from the pipeprint(response.data)

Query a Pipe

fromverdinimporttinybirdclient=tinybird.Client("p.mytoken")pipe=client.pipe("my_pipe")# query the pipe using dynamic parametersresponse:tinybird.PipeJsonResponse=pipe.query({"key":"val"})# print records returned from the pipeprint(response.data)

Append to a DataSource

fromverdinimporttinybirdclient=tinybird.Client("p.mytoken")# will access my_datasource__v0datasource=client.datasource("my_datasource",version=0)# query the pipe using dynamic parametersdatasource.append([    ("col1-row1","col2-row1"),    ("col1-row2","col2-row2"),])

Queue and batch records into a DataSource

fromqueueimportQueuefromthreadingimportThreadfromverdinimporttinybirdfromverdin.workerimportQueuingDatasourceAppenderclient=tinybird.Client("p.mytoken")records=Queue()appender=QueuingDatasourceAppender(records,client.datasource("my_datasource"))Thread(target=appender.run).start()# appender will regularly read batches of data from the queue and append them# to the datasource. the appender respects rate limiting.records.put(("col1-row1","col2-row1"))records.put(("col1-row2","col2-row2"))

Develop

make venvmake test

make format

make upload