DB API

tdclient

tdclient.Binary(string)

tdclient.DateFromTicks(ticks)

tdclient.TimeFromTicks(ticks)

tdclient.TimestampFromTicks(ticks)

tdclient.connect(*args, **kwargs)

Returns a DBAPI compatible connection object

Parameters

• type (str) – query engine type. “hive” by default.

• db (str) – the name of database on Treasure Data

• result_url (str) – result output URL

• priority (str) – job priority

• retry_limit (int) – job retry limit

• wait_interval (int) – job wait interval to check status

• wait_callback (callable) – a callback to be called on every ticks of job wait

Returns

tdclient.connection.Connection

tdclient.connection

class tdclient.connection.Connection(type=None, db=None, result_url=None, priority=None, retry_limit=None, wait_interval=None, wait_callback=None, **kwargs)

Bases: object

close()

commit()

cursor()

rollback()

property api

tdclient.cursor

class tdclient.cursor.Cursor(api, wait_interval=5, wait_callback=None, **kwargs)

Bases: object

callproc(procname, *parameters)

close()

execute(query, args=None)

executemany(operation, seq_of_parameters)

fetchall()

Fetch all (remaining) rows of a query result, returning them as a sequence of sequences (e.g. a list of tuples). Note that the cursor’s arraysize attribute can affect the performance of this operation.

fetchmany(size=None)

Fetch the next set of rows of a query result, returning a sequence of sequences (e.g. a list of tuples). An empty sequence is returned when no more rows are available.

fetchone()

Fetch the next row of a query result set, returning a single sequence, or None when no more data is available.

job_result()

Fetch job results

Returns

Job result in list

job_status()

Show job status

Returns

The status information of the given job id at last execution.

nextset()

setinputsizes(sizes)

setoutputsize(size, column=None)

show_job()

Returns detailed information of a Job

Returns

Detailed information of a job

Return type

dict

property api

property description

property rowcount