Questions tagged [pykka]

Pykka is a set of easy to use concurrency abstractions for Python using the actor model.

The goal of Pykka is to provide easy to use abstractions for Python by using the .

Pykka provides an actor API with two different implementations, ThreadingActor and GeventActor.

Related tags: , ,

11 questions
7
votes
1 answer

pykka -- Actors are slow?

I am currently experimenting with Actor-concurreny (on Python), because I want to learn more about this. Therefore I choosed pykka, but when I test it, it's more than half as slow as an normal function. The Code is only to look if it works; it's not…
Themerius
  • 1,861
  • 1
  • 19
  • 33
6
votes
1 answer

Python actor model: thespian vs pykka

I want to play around with actors in python. Apparently, the two most popular alternatives are thespian and pykka. I'm looking for something actively developed and easy to use. Which would you recommend and why?
Gabriele
  • 469
  • 4
  • 10
6
votes
2 answers

Using Akka actors to invoke or pass messages to Python code

I've a some analysis code that's written in Python. Currently I'm using Storm to process streams. Because Storm allows invocation of python code using message serialization I an invoke Python code from Java/Scala in my Storm bolts. I found Pykka…
Soumya Simanta
  • 11,523
  • 24
  • 106
  • 161
4
votes
1 answer

How to send RabbitMQ messages to Pykka actor?

UPDATE Aug, 2015: For people wanting to use messaging, I currently would recommend zeromq. Could be used in addition to, or as a complete replacement of, pykka. How can I listen to a RabbitMQ queue for messages and then forward them to an actor…
Andriy Drozdyuk
  • 58,435
  • 50
  • 171
  • 272
2
votes
0 answers

How to ask / tell between Java-Akka and Pykka?

I have a Java implementation of Akka Actor as shown below: public class Rule1Actor extends UntypedActor{ @Override public void onReceive(Object message){ ...... } } I need to call some python script within the onReceive method. I…
Kavitha Madhavaraj
  • 562
  • 1
  • 6
  • 23
1
vote
1 answer

Pykka: How to cancel an actor's pending messages queue when it has been stopped

I've playing with Pykka actors library and I came up with the following awesome silly example: import pykka from time import sleep class TestActor(pykka.ThreadingActor): def on_receive(self, message): sleep(1) …
1
vote
0 answers

An actor-based GUI with Pykka and PyQt

Background: This is really an architecture question. I'm looking to port an application currently written in LabView to Python. It is a hardware control and measurement application which basically orchestrates a bunch of heterogeneous hardware to…
Tobin
  • 133
  • 1
  • 7
0
votes
1 answer

Pykka's behaviour with @property setters

I'm playing with pykka's actor model, and found some funny behaviour. Here's a demo that Launches an actor Gets a proxy to it Sets one of its @properties Here's the code: import time import pykka from sys import version_info as python_version if…
CharlieB
  • 704
  • 7
  • 14
0
votes
1 answer

pika's SelectConnection create channel cost 5 seconds when use in pykka

I use pika to communicate with rabbitmq.I consume a queue,when receive a message,i start a pykka's actor to run my logic,sometimes my logic may use the pika connection to publish message.but i found that it will cost 5 seconds to create a channel in…
frh10
  • 1
  • 2
0
votes
1 answer

How to make Pykka log directly to console?

Pykka logs to a logger called pykka. I want all exceptions, debug messages printed to console, especially when running tests that start and stop actors in Pykka written with Mamba. How do I do this?
fatuhoku
  • 4,815
  • 3
  • 30
  • 70
0
votes
1 answer

Pykka: get the base class of an Actor

I use pykka python library. I would like to create an actor, and later test if the actor created is of the proper class. class MyActor( ThreadingActor ): # ... actor = MyActor.start().proxy() assert actor.__class__ == MyActor # check here? Here…
Jakub M.
  • 32,471
  • 48
  • 110
  • 179