airflow.providers.ydb.hooks.ydb¶

属性¶

DEFAULT_YDB_GRPCS_PORT

类¶

`YDBCursor`	YDB 游标包装器。
`YDBConnection`	YDB 连接包装器。
`YDBHook`	与 YDB 交互。

模块内容¶

airflow.providers.ydb.hooks.ydb.DEFAULT_YDB_GRPCS_PORT: int = 2135[source]¶

class airflow.providers.ydb.hooks.ydb.YDBCursor(delegatee, is_ddl)[source]¶

YDB 游标包装器。

delegatee: ydb_dbapi.Cursor[source]¶

is_ddl: bool[source]¶

execute(sql, parameters=None)[source]¶

executemany(sql, seq_of_parameters)[source]¶

executescript(script)[source]¶

fetchone()[source]¶

fetchmany(size=None)[source]¶

fetchall()[source]¶

nextset()[source]¶

setinputsizes(sizes)[source]¶

setoutputsize(column=None)[source]¶

__enter__()[source]¶

__exit__(exc_type, exc_val, exc_tb)[source]¶

close()[source]¶

property rowcount[source]¶

property description[source]¶

class airflow.providers.ydb.hooks.ydb.YDBConnection(database, ydb_session_pool, is_ddl)[source]¶

YDB 连接包装器。

is_ddl[source]¶

delegatee: ydb_dbapi.Connection[source]¶

cursor()[source]¶

begin()[source]¶

commit()[source]¶

rollback()[source]¶

__enter__()[source]¶

__exit__(exc_type, exc_val, exc_tb)[source]¶

close()[source]¶

bulk_upsert(table_name, rows, column_types)[source]¶

class airflow.providers.ydb.hooks.ydb.YDBHook(*args, is_ddl=False, **kwargs)[source]¶

继承自: airflow.providers.common.sql.hooks.sql.DbApiHook

与 YDB 交互。

conn_name_attr: str = 'ydb_conn_id'[source]¶

default_conn_name: str = 'ydb_default'[source]¶

conn_type: str = 'ydb'[source]¶

hook_name: str = 'YDB'[source]¶

supports_autocommit: bool = True[source]¶

supports_executemany: bool = True[source]¶

is_ddl = False[source]¶

database: str[source]¶

ydb_session_pool[source]¶

classmethod get_connection_form_widgets()[source]¶

返回添加到 YDB 连接表单的连接小部件。

classmethod get_ui_field_behaviour()[source]¶

返回 YDB 连接的自定义 UI 字段行为。

property sqlalchemy_url: sqlalchemy.engine.URL[source]¶

从连接返回 Sqlalchemy.engine.URL 对象。

需要在 provider 子类中实现以返回 sqlalchemy.engine.URL 对象。

返回值:: 提取出的 sqlalchemy.engine.URL 对象。
返回类型:: sqlalchemy.engine.URL

get_conn()[source]¶

建立与 YDB 数据库的连接。

bulk_upsert(table_name, rows, column_types)[source]¶

批量更新插入 (BulkUpsert) 到数据库。更优化的插入行到 db 的方式。

另请参阅

https://ydb.tech/docs/en/recipes/ydb-sdk/bulk-upsert