esppy.connectors.TeradataListenerSubscriber

class esppy.connectors.TeradataListenerSubscriber(ingestUrl, SSLCert, sourceKey, name=None, is_active=None, snapshot=None, ingestBlocksize=None, contentType=None, ingestDelim=None)

Bases: esppy.connectors.base.Connector

Subscribe to Teradata Listener events

Parameters

ingestUrlstring

Specifies the URL for the Listener Ingest REST API (version 1)

SSLCertstrirng

Specifies the path to a file that contains SSL certificates securely connect to the Listener Ingest service. Listener uses TLS 1.2.

sourceKeystring

Specifies the Listener source secret key that identifies the Listener source feed to which Event Stream Processing sends data.

ingestBlocksizeint, optional

Specifies the maximum number of data rows to send in one Listener Ingest message. Matching the connector block size to the Source window block size is recommended. The default block size is 256.

contentTypestring, optional

Specifies the format of the data sent from Event Stream Processing to Listener, either JSON or plaintext (comma-delimited). The default is JSON.

ingestDelimstring, optional

Specifies the character that delimits data rows in a multi-row message from Event Stream Processing to the Listener Ingest REST API. The delimiter must not be a JSON punctuation character. The default is a tilde (~).

snapshotboolean, optional

Specifies whether to send snapshot data.

Returns

TeradataListenerSubscriber

__init__(self, ingestUrl, SSLCert, sourceKey, name=None, is_active=None, snapshot=None, ingestBlocksize=None, contentType=None, ingestDelim=None)

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

Methods

__init__(self, ingestUrl, SSLCert, sourceKey)	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