airflow.providers.presto.hooks.presto
¶
Module Contents¶
Classes¶
Interact with Presto through prestodb. |
Functions¶
Return json string with dag_id, task_id, execution_date and try_number |
Attributes¶
- airflow.providers.presto.hooks.presto.generate_presto_client_info()[source]¶
Return json string with dag_id, task_id, execution_date and try_number
- exception airflow.providers.presto.hooks.presto.PrestoException[source]¶
Bases:
Exception
Presto exception
- class airflow.providers.presto.hooks.presto.PrestoHook(*args, schema=None, **kwargs)[source]¶
Bases:
airflow.hooks.dbapi.DbApiHook
Interact with Presto through prestodb.
>>> ph = PrestoHook() >>> sql = "SELECT count(1) AS num FROM airflow.static_babynames" >>> ph.get_records(sql) [[340698]]
- insert_rows(self, table, rows, target_fields=None, commit_every=0, replace=False, **kwargs)[source]¶
A generic way to insert a set of tuples into a table.
- Parameters
table (str) -- Name of the target table
rows (Iterable[tuple]) -- The rows to insert into the table
target_fields (Optional[Iterable[str]]) -- The names of the columns to fill in the table
commit_every (int) -- The maximum number of rows to insert in one transaction. Set to 0 to insert all rows in one transaction.
replace (bool) -- Whether to replace instead of insert