esppy.connectors.ProjectPublisher

class esppy.connectors.ProjectPublisher(srcproject=None, srccontinuousquery=None, srcwindow=None, maxevents=None, configfilesection=None, name=None, is_active=None)

Bases: esppy.connectors.base.Connector

ESP window event publisher

Parameters
srcprojectstring

Specifies the name of the source project

srccontinuousquerystring

Specifies the name of the source continuous query

srcwindowstring

Specifies the name of the Source window

maxeventsint, optional

Specifies the maximum number of events to publish

configfilesectionstring, optional

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

Returns
ProjectPublisher
__init__(self, srcproject=None, srccontinuousquery=None, srcwindow=None, maxevents=None, configfilesection=None, name=None, is_active=None)

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

Methods

__init__(self[, srcproject, …])

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