本文整理汇总了Python中wishbone.event.Event类的典型用法代码示例。如果您正苦于以下问题:Python Event类的具体用法?Python Event怎么用?Python Event使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Event类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: test_event_appendBulk
def test_event_appendBulk():
e = Event(bulk=True)
ee = Event({"one": 1})
e.appendBulk(ee)
assert e.dump()["data"][0]["uuid"] == ee.data["uuid"]
开发者ID:smetj,项目名称:wishbone,代码行数:7,代码来源:test_event.py
示例2: test_module_unpack
def test_module_unpack():
actor_config = ActorConfig('unpack', 100, 1, {}, "")
unpack = Unpack(actor_config)
unpack.pool.queue.inbox.disableFallThrough()
unpack.pool.queue.outbox.disableFallThrough()
unpack.start()
bulk = Event(bulk=True)
for _ in range(0, 10):
bulk.appendBulk(Event())
unpack.pool.queue.inbox.put(bulk)
for _ in range(0, 10):
assert getter(unpack.pool.queue.outbox)
try:
getter(unpack.pool.queue.outbox)
except Exception:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:25,代码来源:test_module_unpack.py
示例3: test_module_fanout
def test_module_fanout():
actor_config = ActorConfig('fanout', 100, 1, {})
fanout = Fanout(actor_config, deep_copy=True)
fanout.pool.queue.inbox.disableFallThrough()
fanout.pool.createQueue("one")
fanout.pool.queue.one.disableFallThrough()
fanout.pool.createQueue("two")
fanout.pool.queue.two.disableFallThrough()
fanout.start()
e = Event('test')
e.setData("hello")
fanout.pool.queue.inbox.put(e)
one = getter(fanout.pool.queue.one)
two = getter(fanout.pool.queue.two)
fanout.stop()
assert one.raw()["test"]["data"] == "hello"
assert two.raw()["test"]["data"] == "hello"
assert id(one) != id(two)
开发者ID:tf198,项目名称:wishbone,代码行数:26,代码来源:test_module_fanout.py
示例4: test_event_clone
def test_event_clone():
a = Event({"one": 1, "two": 2})
b = a.clone()
assert id(a.data) != id(b.data)
assert not a.data["cloned"]
assert b.data["cloned"]
assert b.data["uuid_previous"][0] == a.data["uuid"]
开发者ID:smetj,项目名称:wishbone,代码行数:9,代码来源:test_event.py
示例5: test_event_get_error
def test_event_get_error():
e = Event({"one": 1, "two": {"three": 3}})
try:
e.get("data.blah")
except KeyError:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:9,代码来源:test_event.py
示例6: test_event_render_error
def test_event_render_error():
e = Event({"one": 1, "two": 2})
try:
e.render("{{data.one} is a number and so is {{data.two}}")
except InvalidData:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:10,代码来源:test_event.py
示例7: test_merge_fail
def test_merge_fail():
e = Event("hi")
try:
e.merge(["two"])
except InvalidData:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:10,代码来源:test_event.py
示例8: test_extractBulkItems
def test_extractBulkItems():
from wishbone.event import extractBulkItems
e = Event(bulk=True)
e.appendBulk(Event({"one": 1}))
e.appendBulk(Event({"two": 2}))
e.appendBulk(Event({"three": 3}))
for item in extractBulkItems(e):
assert isinstance(item, Event)
开发者ID:smetj,项目名称:wishbone,代码行数:11,代码来源:test_event.py
示例9: test_event_delete
def test_event_delete():
a = Event({"one": 1, "two": 2})
a.delete("data.two")
try:
a.get("data.two")
except KeyError:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:11,代码来源:test_event.py
示例10: test_extractBulkItemValues
def test_extractBulkItemValues():
from wishbone.event import extractBulkItemValues
e = Event(bulk=True)
e.appendBulk(Event({"one": 1}))
e.appendBulk(Event({"two": 2}))
e.appendBulk(Event({"three": 3}))
for item in extractBulkItemValues(e, "data"):
assert item in [{"one": 1}, {"two": 2}, {"three": 3}]
开发者ID:smetj,项目名称:wishbone,代码行数:11,代码来源:test_event.py
示例11: __log
def __log(self, level, message):
event = Event(self.name)
event.data = Log(time(), level, getpid(), self.name, message)
while True:
try:
self.logs.put(event)
break
except QueueFull:
sleep(0.1)
开发者ID:tf198,项目名称:wishbone,代码行数:11,代码来源:logging.py
示例12: metricProducer
def metricProducer(self):
'''A greenthread which collects the queue metrics at the defined interval.'''
self.__run.wait()
hostname = socket.gethostname()
while self.loop():
for queue in self.pool.listQueues(names=True):
for metric, value in self.pool.getQueue(queue).stats().iteritems():
event = Wishbone_Event(self.name)
event.data = Metric(time=time(), type="wishbone", source=hostname, name="module.%s.queue.%s.%s" % (self.name, queue, metric), value=value, unit="", tags=())
self.submit(event, self.pool.queue.metrics)
sleep(self.frequency)
开发者ID:tf198,项目名称:wishbone,代码行数:12,代码来源:actor.py
示例13: test_event_slurp_bad
def test_event_slurp_bad():
a = Event()
del(a.data["uuid"])
b = Event()
try:
b.slurp(a.dump())
except InvalidData:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:12,代码来源:test_event.py
示例14: test_event_appendBulkFull
def test_event_appendBulkFull():
e = Event(bulk=True, bulk_size=1)
ee = Event({"one": 1})
e.appendBulk(ee)
try:
e.appendBulk(ee)
except BulkFull:
assert True
else:
assert False
开发者ID:smetj,项目名称:wishbone,代码行数:12,代码来源:test_event.py
示例15: processEvent
def processEvent(self, data, meta, queue):
'''
The callback executed for each Wishbone event to be created out of a
single http request.
'''
e = Event(data)
e.set(meta, 'tmp.%s' % (self.name))
e.renderKwargs(self.kwargs_template)
self.submit(e, queue)
return self.getResponse(e, queue)
开发者ID:smetj,项目名称:wishbone-input-httpserver,代码行数:12,代码来源:httpserver.py
示例16: test_event_dump
def test_event_dump():
from wishbone.event import EVENT_RESERVED
data = {"one": 1, "two": 2}
a = Event(data)
result = a.dump()
for key in EVENT_RESERVED:
assert key in result
assert result["data"] == data
assert isinstance(result["timestamp"], float)
开发者ID:smetj,项目名称:wishbone,代码行数:13,代码来源:test_event.py
示例17: generateEvent
def generateEvent(self, data={}, destination=None):
'''
Generates a new event.
This function can get overridden by
``wishbone.module.InputModule._generateNativeEvent``.
The provided ``data`` will be traversed in search of valid templates
which then will be rendered.
Args:
data (``data``): The payload to add to the event.
destination (None): The destination key to write the data to
Returns:
wishbone.event.Event: An event containing ``data`` as a payload.
'''
if destination in [None, "data"]:
event = Wishbone_Event(data)
event.renderField(destination, self.env_template)
else:
event = Wishbone_Event()
event.set(data, destination)
event.renderField(destination, self.env_template)
return event
开发者ID:smetj,项目名称:wishbone,代码行数:26,代码来源:actor.py
示例18: test_module_msgpackdecode
def test_module_msgpackdecode():
actor_config = ActorConfig('msgpackdecode', 100, 1, {})
msgpackdecode = MSGPackDecode(actor_config)
msgpackdecode.pool.queue.inbox.disableFallThrough()
msgpackdecode.pool.queue.outbox.disableFallThrough()
msgpackdecode.start()
e = Event('test')
e.setData('\x93\x01\x02\x03')
msgpackdecode.pool.queue.inbox.put(e)
one = getter(msgpackdecode.pool.queue.outbox)
assert one.data == [1, 2, 3]
开发者ID:tf198,项目名称:wishbone,代码行数:15,代码来源:test_module_msgpackdecode.py
示例19: test_module_jsonencode
def test_module_jsonencode():
actor_config = ActorConfig('jsonencode', 100, 1, {})
jsonencode = JSONEncode(actor_config)
jsonencode.pool.queue.inbox.disableFallThrough()
jsonencode.pool.queue.outbox.disableFallThrough()
jsonencode.start()
e = Event('test')
e.setData(["one", "two", "three"])
jsonencode.pool.queue.inbox.put(e)
one = getter(jsonencode.pool.queue.outbox)
assert one.data == '["one", "two", "three"]'
开发者ID:tf198,项目名称:wishbone,代码行数:15,代码来源:test_module_jsonencode.py
示例20: test_module_msgpackencode
def test_module_msgpackencode():
actor_config = ActorConfig("msgpackencode", 100, 1, {})
msgpackencode = MSGPackEncode(actor_config)
msgpackencode.pool.queue.inbox.disableFallThrough()
msgpackencode.pool.queue.outbox.disableFallThrough()
msgpackencode.start()
e = Event("test")
e.setData([1, 2, 3])
msgpackencode.pool.queue.inbox.put(e)
one = getter(msgpackencode.pool.queue.outbox)
assert one.data == "\x93\x01\x02\x03"
开发者ID:tf198,项目名称:wishbone,代码行数:15,代码来源:test_module_msgpackencode.py
注:本文中的wishbone.event.Event类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论