本文整理汇总了Python中wishbone.Actor类的典型用法代码示例。如果您正苦于以下问题：Python Actor类的具体用法？Python Actor怎么用？Python Actor使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Actor类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: __init__
def __init__(self, actor_config, complete=False):
Actor.__init__(self, actor_config)
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:smetj，项目名称:wishbone-encode-msgpack，代码行数:7，代码来源:msgpackencode.py
示例2: __init__
def __init__(self, name, size=100, frequency=1, sanitize_hostname=False):
Actor.__init__(self, name, size, frequency)
self.regex = re.compile('(.*?)(\D+)$')
self.sanitize_hostname = sanitize_hostname
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:smetj，项目名称:metricfactory，代码行数:7，代码来源:modgearman.py
示例3: __init__
def __init__(self, name, size=100, frequency=1, meta=False):
Actor.__init__(self, name, size, frequency)
self.name = name
self.meta = meta
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:smetj，项目名称:metricfactory，代码行数:7，代码来源:ganglia.py
示例4: __init__
def __init__(self, name, host="localhost", port=19283, timeout=10, delimiter="\n", success=False, failed=False):
Actor.__init__(self, name, setupbasic=False)
self.createQueue("inbox")
self.queuepool.inbox.putLock()
self.registerConsumer(self.consume, self.queuepool.inbox)
self.name=name
self.host=host
self.port=port
self.timeout=timeout
self.delimiter=delimiter
self.__reconnect=Event()
self.__reconnect.set()
if success == True:
self.createQueue("successful")
self.submitSuccess=self.__submitSuccess
else:
self.submitSuccess=self.__noSubmitSuccess
if failed == True:
self.createQueue("failed")
self.submitFailed=self.__submitFailed
self.disableConsuming=self.noDisableConsuming
else:
self.submitFailed=self.__noSubmitFailed
开发者ID:Lacrymology，项目名称:wishboneModules，代码行数:26，代码来源:tcp.py
示例5: __init__
def __init__(self, name, size=100, frequency=1, capitalize=False):
Actor.__init__(self, name, size, frequency)
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
self.capitalize = capitalize
开发者ID:jeredding，项目名称:wishbone，代码行数:7，代码来源:reversedata.py
示例6: __init__
def __init__(self, name, size=1, frequency=1, host="localhost", port=5672, vhost="/", user="guest", password="guest",
exchange="", exchange_type="direct", exchange_durable=False,
queue="wishbone", queue_durable=False, queue_exclusive=False, queue_auto_delete=True, queue_declare=True,
routing_key="", prefetch_count=1, no_ack=False):
Actor.__init__(self, name, size, frequency)
self.name = name
self.size = size
self.host = host
self.port = port
self.vhost = vhost
self.user = user
self.password = password
self.exchange = exchange
self.exchange_type = exchange_type
self.exchange_durable = exchange_durable
self.queue = queue
self.queue_durable = queue_durable
self.queue_exclusive = queue_exclusive
self.queue_auto_delete = queue_auto_delete
self.queue_declare = queue_declare
self.routing_key = routing_key
self.prefetch_count = prefetch_count
self.no_ack = no_ack
self.pool.createQueue("outbox")
self.pool.createQueue("ack")
self.pool.queue.ack.disableFallThrough()
开发者ID:jeredding，项目名称:wishbone，代码行数:27，代码来源:amqpin.py
示例7: __init__
def __init__(self, actor_config, min=1, max=100):
Actor.__init__(self, actor_config)
self.pool.createQueue("inbox")
self.pool.createQueue("inside")
self.pool.createQueue("outside")
self.registerConsumer(self.consume, "inbox")
开发者ID:tf198，项目名称:wishbone，代码行数:7，代码来源:biggerandsmaller.py
示例8: __init__
def __init__(self, actor_config):
Actor.__init__(self, actor_config)
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
self.tags = {}
开发者ID:tf198，项目名称:wishbone，代码行数:7，代码来源:influxdb.py
示例9: __init__
def __init__(self, name, complete=False, counter=False, prefix="", pid=False):
Actor.__init__(self, name)
self.deleteQueue("outbox")
self.complete=complete
self.counter=counter
self.prefix=prefix
self.format=Format(complete, counter, pid)
开发者ID:Lacrymology，项目名称:wishbone，代码行数:7，代码来源:stdout.py
示例10: __init__
def __init__(self, name, size=100, frequency=1, port=19283, timeout=10, topic=""):
Actor.__init__(self, name, size, frequency)
self.port = port
self.timeout = timeout
self.topic = topic
self.pool.createQueue("inbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:jeredding，项目名称:wishbone，代码行数:7，代码来源:zmqtopicout.py
示例11: __init__
def __init__(self, actor_config, host="127.0.0.1", port=19283, delimiter=""):
Actor.__init__(self, actor_config)
self.pool.createQueue("inbox")
self.registerConsumer(self.consume, "inbox")
self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
开发者ID:tf198，项目名称:wishbone，代码行数:7，代码来源:udpout.py
示例12: __init__
def __init__(self, name, path="/tmp/%s.namedpipe"%(os.getpid())):
Actor.__init__(self, name, setupbasic=False)
self.createQueue("outbox")
self.name=name
self.path = path
self.__data = event.Event()
self.__data.clear()
开发者ID:lihuimail，项目名称:wishboneModules，代码行数:7，代码来源:namedpipe.py
示例13: __init__
def __init__(self, name, filename=None, randomize_keys=True, num_values=False, num_values_min=0, num_values_max=1, min_elements=1, max_elements=1, sleep=0 ):
Actor.__init__(self, name, setupbasic=False)
self.createQueue("outbox")
self.name = name
self.filename=filename
self.randomize_keys=randomize_keys
self.num_values=num_values
self.num_values_min=num_values_min
self.num_values_max=num_values_max
self.min_elements=min_elements
self.max_elements=max_elements
self.wordlist=self.readWordList(self.filename)
self.sleep=sleep
self.key_number=-1
if self.randomize_keys == True:
self.generateKey = self.pickWord
else:
self.generateKey = self.generateKeyNumber
if self.num_values == True:
self.generateValue = self.generateValueNumber
else:
self.generateValue = self.pickWord
开发者ID:Lacrymology，项目名称:wishboneModules，代码行数:25，代码来源:wb__input_dictgenerator.py
示例14: __init__
def __init__(self, name, size, frequency, url="http://localhost", username=None, password=None, interval=60):
Actor.__init__(self, name, size, frequency)
self.pool.createQueue("outbox")
self.url = url
self.username = username
self.password = password
self.interval = interval
开发者ID:jeredding，项目名称:wishbone，代码行数:7，代码来源:httpinclient.py
示例15: __init__
def __init__(self, name, size=100, frequency=1, path="/tmp/wishbone", delimiter=""):
Actor.__init__(self, name, size, frequency)
self.path = path
self.delimiter = delimiter
self.pool.createQueue("inbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:jeredding，项目名称:wishbone，代码行数:7，代码来源:udsout.py
示例16: __init__
def __init__(self, name, size=100, frequency=1, mode="server", interface="0.0.0.0", port=19283, servers=[]):
Actor.__init__(self, name, size, frequency)
self.mode = mode
self.interface = interface
self.port = port
self.servers = servers
self.pool.createQueue("outbox")
开发者ID:jeredding，项目名称:wishbone，代码行数:7，代码来源:zmqpullin.py
示例17: __init__
def __init__(self, actor_config, selection="@data", bind="0.0.0.0", port=19283, show_last=False, keepalive=False, keepalive_interval=5, destination=""):
Actor.__init__(self, actor_config)
self.pool.createQueue("inbox")
self.registerConsumer(self.consume, "inbox")
self.session_queues = {}
self.template = self.__getTemplate()
开发者ID:smetj，项目名称:wishbone-output-sse，代码行数:7，代码来源:sse.py
示例18: __init__
def __init__(self, name, size=100, frequency=1, source="rabbitmq"):
Actor.__init__(self, name, size, frequency)
self.logging.info("Initialized")
self.source = source
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
开发者ID:smetj，项目名称:metricfactory，代码行数:7，代码来源:rabbitmq.py
示例19: __init__
def __init__(self, name, size=100, frequency=1, source="elasticsearch", indices=[]):
Actor.__init__(self, name, size, frequency)
self.pool.createQueue("inbox")
self.pool.createQueue("outbox")
self.registerConsumer(self.consume, "inbox")
self.logging.info("Initialized")
self.source = source
self.indices = indices
开发者ID:smetj，项目名称:metricfactory，代码行数:8，代码来源:elasticsearch.py
示例20: __init__
def __init__(self, name, server="http://127.0.0.1:9200", ):
Actor.__init__(self, name, setupbasic=True)
self.createQueue("rescue")
self.server=server
self.logging.info("Initialized")
self.queuepool.inbox.putLock()
self.conn=self.getConnection()
self.__connecting=False
开发者ID:Lacrymology，项目名称:wishboneModules，代码行数:8，代码来源:elasticsearch.py
注：本文中的wishbone.Actor类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论