pykka

5熱度

1回答

我目前正在試用Actor-concurreny（在Python上），因爲我想了解更多。所以我選擇了pykka，但是當我測試的時候，它比多了一半，慢了作爲一個正常的功能。該代碼只是看它是否工作;它並不意味着優雅。 :) 也許我做錯了什麼？ from pykka.actor import ThreadingActor import numpy as np class Adder(Threadi

3熱度

2回答

使用Akka actors來調用或傳遞消息給Python代碼

我有一些用Python編寫的分析代碼。目前我正在使用Storm來處理流。因爲Storm允許使用消息序列化來調用python代碼，所以我在Storm風格的螺栓中調用Java/Scala中的Python代碼。我發現Pykka這是actor模型的Python實現。我想知道是否有辦法從Akka actors中調用Python代碼？例如，是否有可能將來自Akka演員的消息傳遞給Pykka演員？

0熱度

1回答

如何使Pykka直接登錄到控制檯？

Pykka登錄到名爲pykka的記錄器。我想要所有的異常，調試消息打印到控制檯，尤其是當運行測試，啓動和停止在用Mamba寫的Pykka中的actor。我該怎麼做？

0熱度

1回答

Pykka：獲取Actor的基類

我使用pykka python庫。我想創建一個演員，然後測試創建的演員是否屬於正確的類。 class MyActor(ThreadingActor): # ... actor = MyActor.start().proxy() assert actor.__class__ == MyActor # check here? 這裏actor.__class__是pykka.act

0熱度

1回答

pika的SelectConnection在pykka中使用時創建通道花費5秒

我使用pika與rabbitmq進行通信。我消耗一個隊列，當收到消息時，我啓動一個pykka的演員來運行我的邏輯，有時候我的邏輯可能會使用pika連接發佈message.but我發現，這將花費5秒創造actor.Here通道是代碼： def on_conn_open(connection): connection.channel(lambda ch:ch.basic_consume(on

4熱度

1回答

如何發送RabbitMQ消息給Pykka演員？

更新2015年8月：對於想要使用消息傳遞的人，我目前會推薦使用zeromq。可以用作pykka的補充或完全替代。我該如何聆聽RabbitMQ隊列中的消息，然後將它們轉發給Pykka中的演員？目前，當我嘗試這樣做時，我會發現奇怪的行爲，系統停下來停下來。這裏是我有我的演員來實現： class EventListener(eventlet.EventletActor): def __i