esppy.connectors.TeradataSubscriber

class esppy.connectors.TeradataSubscriber(tdatatdpid=None, desttablename=None, tdatausername=None, tdatauserpwd=None, tdataminsessions=None, tdatamaxsessions=None, tdatadriver=None, tdatainsertonly=None, name=None, is_active=None, snapshot=None, rmretdel=None, tdatabatchperiod=None, stage1tablename=None, stage2tablename=None, connectstring=None, tdatatracelevel=None, configfilesection=None, tdatauserpwdencrypted=None)

Bases: esppy.connectors.base.Connector

Subscribe to Teradata operations

Parameters

tdatatdpidstring

Specifies the target Teradata server name

desttablenamestring

Specifies the target table name

tdatausernamestring

Specifies the user name for the user account on the target Teradata server.

tdatauserpwdstring

Specifies the user password for the user account on the target Teradata server.

tdatamaxsessionsint

Specifies the maximum number of sessions created by the TPT to the Teradata server.

tdataminsessionsint

Specifies the minimum number of sessions created by the TPT to the Teradata server.

tdatadriverstring

Specifies the operator: stream, update, or load.

tdatainsertonlyboolean

Specifies whether events in the subscriber event stream processing window are insert only. Must be true when using the load operator.

snapshotboolean

Specifies whether to send snapshot data

rmretdelboolean, optional

Removes all delete events from event blocks received by the subscriber that were introduced by a window retention policy.

tdatabatchperiodint, optional

Specifies the batch period in seconds. Required when using the update operator, otherwise ignored.

stage1tablenamestring, optional

Specifies the first staging table. Required when using the load operator, otherwise ignored.

stage2tablenamestring, optional

Specifies the second staging table. Required when using the load operator, otherwise ignored.

connectstringstring, optional

Specifies the connect string used to access the target and staging tables. Use the form “DSN=dsnname;UID=userid;pwd=password”. Required when using the load operator, otherwise ignored.

connectstringstring, optional

Specifies the connect string used to access the target and staging tables.

tdatatracelevelint, optional

Specifies the trace level for Teradata messages written to the trace file in the current working directory.

configfilesectionstring, optional

Specifies the name of the section in the connector config file to parse for configuration parameters. Specify the value as [configfilesection].

tdatauserpwdencryptedboolean, optional

Specifies that tdatauserpwd is encrypted

Returns

TeradataSubscriber

__init__(self, tdatatdpid=None, desttablename=None, tdatausername=None, tdatauserpwd=None, tdataminsessions=None, tdatamaxsessions=None, tdatadriver=None, tdatainsertonly=None, name=None, is_active=None, snapshot=None, rmretdel=None, tdatabatchperiod=None, stage1tablename=None, stage2tablename=None, connectstring=None, tdatatracelevel=None, configfilesection=None, tdatauserpwdencrypted=None)

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(self[, tdatatdpid, desttablename, …])	Initialize self.
clear(self)
copy(self[, deep])	Return a copy of the object
from_element(data[, session])	Construct connector from XML definition
from_parameters(conncls[, type, name, …])
from_xml(data[, session])	Construct connector from XML definition
get(self, key[, default])
items(self)
keys(self)
pop(self, key[, default])	If key is not found, d is returned if given, otherwise KeyError is raised.
popitem(self)	as a 2-tuple; but raise KeyError if D is empty.
set_properties(self, \*\*kwargs)	Set connector properties
setdefault(self, key[, default])
to_element(self)	Export connector definition to ElementTree.Element
to_xml(self[, pretty])	Export connector definition to XML
update(\*args, \*\*kwds)	If E present and has a .keys() method, does: for k in E: D[k] = E[k] If E present and lacks .keys() method, does: for (k, v) in E: D[k] = v In either case, this is followed by: for k, v in F.items(): D[k] = v
values(self)

Attributes

connector_key
property_defs