Documentation for pulsar 0.9.2. For development docs, go here.
An asynchronous shell for experimenting with pulsar on the command line.
To use write a little script, lets call it pshell.py
:
from pulsar.apps.shell import PulsarShell
if __name__ == '__main__':
PulsarShell().start()
And run it:
python pshell.py
The shell has already pulsar
, get_actor()
, spawn()
,
send()
and the Actor
class in the global dictionary:
>>> pulsar.__version__
0.8.0
>>> actor = get_actor()
>>> actor.info_state
'running'
>>> a = spawn()
>>> a.done()
True
>>> proxy = a.result()
pulsar.apps.shell.
PulsarShell
(callable=None, load_config=True, **params)[source]¶monitor_start
(monitor)[source]¶make sure workers and
thread_workers are both set to 1 and
concurrency is thread
.