tabsdata.subscriber#
- subscriber(tables: TableInput | str | List[str], destination: AzureDestination | LocalFileDestination | MariaDBDestination | MySQLDestination | OracleDestination | PostgresDestination | S3Destination | DestinationPlugin, name: str = None, trigger_by: str | List[str] | None = '*') callable[source]#
- Decorator to set the data and destination parameters of a function and
convert it to a TabsdataFunction.
- Parameters:
tables (TableInput | str | List[str]) – Where to obtain the data that will be provided as an input to the function.
| (destination (AzureDestination | LocalFileDestination | MariaDBDestination) – MySQLDestination | OracleDestination | PostgresDestination | S3Destination | DestinationPlugin): Where to store the output of the function.
name (str, optional) – The name with which the function will be registered. If not provided, the current function name will be used.
trigger_by (str | list[str] | None, optional) – The trigger that will cause the function to execute. It can be a table in the system, a list of tables, or None (in which case it must be triggered manually). Defaults to all dependencies.
- Returns:
The function converted to a TabsdataFunction.
- Return type:
callable