airflow.providers.slack.transfers.base_sql_to_slack¶

Classes¶

BaseSqlToSlackOperator

Operator implements base sql methods for SQL to Slack Transfer operators.

Module Contents¶

class airflow.providers.slack.transfers.base_sql_to_slack.BaseSqlToSlackOperator(*, sql, sql_conn_id, sql_hook_params=None, parameters=None, slack_proxy=None, slack_timeout=None, slack_retry_handlers=None, **kwargs)[source]¶

Bases: airflow.providers.slack.version_compat.BaseOperator

Operator implements base sql methods for SQL to Slack Transfer operators.

Parameters:

sql (str) – The SQL query to be executed
sql_conn_id (str) – reference to a specific DB-API Connection.
sql_hook_params (dict | None) – Extra config params to be passed to the underlying hook. Should match the desired hook constructor params.
parameters (list | tuple | collections.abc.Mapping[str, Any] | None) – The parameters to pass to the SQL query.
slack_proxy (str | None) – Proxy to make the Slack Incoming Webhook / API calls. Optional
slack_timeout (int | None) – The maximum number of seconds the client will wait to connect and receive a response from Slack. Optional
slack_retry_handlers (list[slack_sdk.http_retry.RetryHandler] | None) – List of handlers to customize retry logic. Optional

sql_conn_id[source]¶

sql_hook_params = None[source]¶

sql[source]¶

parameters = None[source]¶

slack_proxy = None[source]¶

slack_timeout = None[source]¶

slack_retry_handlers = None[source]¶