subscriber

functionView source ↗

def subscriber(
    tables: TableInput | str | List[str],
    destination: AzureDestination | LocalFileDestination | MariaDBDestination | MySQLDestination | OracleDestination | PostgresDestination | S3Destination | DestinationPlugin,
    name: str = None,
    trigger_by: SubscriberTriggerBySpec = '*',
) -> callable

Categories: subscriber

Decorator to define a function to subscribe to data present in Tabsdata.

Parameters

parameter

tables

Where to obtain the data that will be provided as an input to the function.

parameter

destination

Where to store the output of the function.

parameter

name

The name with which the function will be registered. If not provided, the current function name will be used.

parameter

trigger_by

The trigger that will cause the function to execute. It can be a table in the system, a list of tables, None (in which case it must be triggered manually), or a CronTrigger. Defaults to all dependencies.

Returns

callable: The function converted to a Tabsdata Function.