| | |
- siirto.base.Base(builtins.object)
-
- CDCBase
class CDCBase(siirto.base.Base) |
| |
CDC base plugin.
All CDC plugins will be derived from this plugin
To derive this class, you are expected to override the constructor
as well as the 'execute' method.
This run a single instance for all the tables required to
collect CDC.
:param output_folder_location: location to write the Copy
command data
:type output_folder_location: str
:param connection_string: postgres connection string
:type connection_string: str
:param table_names: table names to be copied. Table name should
be schema.table_name. for example, public.user_detail
:type table_names: List[str]
|
| |
- Method resolution order:
- CDCBase
- siirto.base.Base
- builtins.object
Methods defined here:
- __init__(self, output_folder_location:str=None, connection_string:str=None, table_names:List[str]=[], *args, **kwargs) -> None
- Initialize self. See help(type(self)) for accurate signature.
- execute(self)
- This is the main method to derive when implementing an operator.
- setup_graceful_shutdown(self)
- Handles graceful shutdown in case of failures
Class methods defined here:
- get_object(plugin_name:str) from builtins.type
- Factory.
Get the cdc plugin object having name `plugin_name`
:param plugin_name: plugin name
:return: cdc plug_in
- load_derived_classes() from builtins.type
- load the derived cdc plugin classes available in the current directory and
ending with _plugin.py
Data and other attributes defined here:
- plugin_name = None
- plugin_type = <PlugInType.CDC: 2>
Data descriptors inherited from siirto.base.Base:
- __dict__
- dictionary for instance variables (if defined)
- __weakref__
- list of weak references to the object (if defined)
| |