mode · PyPI

Version:: 1.1.1
Web:: http://mode.readthedocs.org/
Download:: http://pypi.python.org/pypi/mode
Source:: http://github.com/fauststream/mode
Keywords:: async, service, framework, actors, bootsteps, graph

What is Mode?

Mode is a library for Python AsyncIO, using the new async/await syntax in Python 3.6 to define your program as a set of services.

When starting a larger project using asyncio, it immediately became apparent that we needed a way to manage the different services running in the program. Questions such as “how do we shutdown the event loop” is frequently answered by telling users to “wait for all coroutines in asyncio.Task.all_tasks”, but we needed more control over what services where stopped, in what order and what services can we safely shutdown without waiting for current operations to complete.

So for us the answer was to create a generic Service class that handles this for us, including creating pretty graphs of active services in the system, and what they are currently doing.

Heavily inspired by Celery/RabbitMQ bootsteps, you could say it’s a less formal version of that, where the graph is built at runtime.

Creating a Service

To define a service, simply subclass and fill in the methods to do stuff as the service is started/stopped etc.:

class MyService(Service):

    async def on_start(self) -> None:
        print('Im starting now')

    async def on_started(self) -> None:
        print('Im ready')

    async def on_stop(self) -> None:
        print('Im stopping now')

To start the service, call await service.start():

await service.start()

Or you can use mode.Worker (or a subclass of this) to start your services-based asyncio program from the console:

if __name__ == '__main__':
    imoport mode
    worker = mode.Worker(MyService(), loglevel='INFO', logfile=None)
    worker.execute_from_commandline()

It’s a Graph!

Services can start other services, coroutines, and background tasks.

Starting other services using add_depenency:

class MyService(Service):

    def on_init(self) -> None:
       self.add_dependency(OtherService(loop=self.loop))

Start a list of services using on_init_dependencies:

class MyService(Service):

    def on_init_dependencies(self) -> None:
        return [
            ServiceA(loop=self.loop),
            ServiceB(loop=self.loop),
            ServiceC(loop=self.loop),
        ]

Start a future/coroutine (that will be waited on to complete on stop):

class MyService(Service):

    async def on_start(self) -> None:
        self.add_future(self.my_coro())

    async def my_coro(self) -> None:
        print('Executing coroutine')

Start a background task:

class MyService(Service):

    @Service.task
    async def _my_coro(self) -> None:
        print('Executing coroutine')

Start a background task that keeps running:

class MyService(Service):

    @Service.task
    async def _my_coro(self) -> None:
        while not self.should_stop:
            # NOTE: self.sleep will wait for one second, or
            #       until service stopped/crashed.
            await self.sleep(1.0)
            print('Background thread waking up')

Installation

You can install Mode either via the Python Package Index (PyPI) or from source.

To install using pip:

$ pip install -U mode

Downloading and installing from source

Download the latest version of Mode from http://pypi.python.org/pypi/mode

You can install it by doing the following:

$ tar xvfz mode-0.0.0.tar.gz
$ cd mode-0.0.0
$ python setup.py build
# python setup.py install

The last command must be executed as a privileged user if you are not currently using a virtualenv.

Using the development version

With pip

You can install the latest snapshot of Mode using the following pip command:

$ pip install https://github.com/fauststream/Mode/zipball/master#egg=mode

FAQ

Can I use Mode with Django/Flask/etc.?

Yes! Use gevent/eventlet and use a bridge to integrate with asyncio.

aiogevent enables you to run Mode on top of gevent:

https://pypi.python.org/pypi/aiogevent

Example:

import aiogevent
import asyncio
asyncio.set_event_loop_policy(aiogevent.EventLoopPolicy())
import gevent.monkey
gevent.monkey.patch_all()
# if you use PostgreSQL with psycopg, make sure you also
# install psycogreen and call this pather:
#  import psycogreen.gevent
#  psycogreen.gevent.patch_psycopg()

# Import Django/Flask etc, stuff and use them with Mode.

aioeventlet enables you to run Mode on top of eventlet:

http://aioeventlet.readthedocs.io

Example:

import aioeventlet
import asyncio
asyncio.set_event_loop_policy(aioeventlet.EventloopPolicy())
import eventlet
eventlet.monkey_patch()
# if you use PostgreSQL with psycopg, make sure you also
# install psycogreen and call this pather:
#  import psycogreen.eventlet
#  psycogreen.eventlet.patch_psycopg()

# Import Django/Flask etc, stuff and use them with Mode.

Can I use Mode with Tornado?

Yes! Use the tornado.platform.asyncio bridge: http://www.tornadoweb.org/en/stable/asyncio.html

Can I use Mode with Twisted?

Yes! Use the asyncio reactor implementation: https://twistedmatrix.com/documents/17.1.0/api/twisted.internet.asyncioreactor.html

Will you support Python 3.5 or earlier?

There are no immediate plans to support Python 3.5, but you are welcome to contribute to the project.

Here are some of the steps required to accomplish this:

Source code transformation to rewrite variable annotations to comments

for example, the code:

     class Point:
         x: int = 0
         y: int = 0

must be rewritten into::

     class Point:
         x = 0  # type: int
         y = 0  # type: int

Source code transformation to rewrite async functions

for example, the code:
async def foo():
    await asyncio.sleep(1.0)
must be rewritten into:
@coroutine
def foo():
    yield from asyncio.sleep(1.0)

Will you support Python 2?

There are no plans to support Python 2, but you are welcome to contribute to the project (details in question above is relevant also for Python 2).

Code of Conduct

Everyone interacting in the project’s codebases, issue trackers, chat rooms, and mailing lists is expected to follow the Mode Code of Conduct.

As contributors and maintainers of these projects, and in the interest of fostering an open and welcoming community, we pledge to respect all people who contribute through reporting issues, posting feature requests, updating documentation, submitting pull requests or patches, and other activities.

We are committed to making participation in these projects a harassment-free experience for everyone, regardless of level of experience, gender, gender identity and expression, sexual orientation, disability, personal appearance, body size, race, ethnicity, age, religion, or nationality.

Examples of unacceptable behavior by participants include:

The use of sexualized language or imagery
Personal attacks
Trolling or insulting/derogatory comments
Public or private harassment
Publishing other’s private information, such as physical or electronic addresses, without explicit permission
Other unethical or unprofessional conduct.

Project maintainers have the right and responsibility to remove, edit, or reject comments, commits, code, wiki edits, issues, and other contributions that are not aligned to this Code of Conduct. By adopting this Code of Conduct, project maintainers commit themselves to fairly and consistently applying these principles to every aspect of managing this project. Project maintainers who do not follow or enforce the Code of Conduct may be permanently removed from the project team.

This code of conduct applies both within project spaces and in public spaces when an individual is representing the project or its community.

Instances of abusive, harassing, or otherwise unacceptable behavior may be reported by opening an issue or contacting one or more of the project maintainers.

This Code of Conduct is adapted from the Contributor Covenant, version 1.2.0 available at http://contributor-covenant.org/version/1/2/0/.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

mode-1.1.1.tar.gz (596.4 kB view details)

Uploaded Oct 25, 2017 Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

The dropdown lists show the available interpreters, ABIs, and platforms. Enable javascript to be able to filter the list of wheel files.

mode-1.1.1-py2.py3-none-any.whl (46.0 kB view details)

Uploaded Oct 25, 2017 Python 2Python 3

File details

Details for the file mode-1.1.1.tar.gz.

File metadata

Download URL: mode-1.1.1.tar.gz
Upload date: Oct 25, 2017
Size: 596.4 kB
Tags: Source
Uploaded using Trusted Publishing? No

File hashes

Hashes for mode-1.1.1.tar.gz
Algorithm	Hash digest
SHA256	`4938c5f7f979414bbb95e7cb86cfe118c46aa14e84167f0949e31b503f5ec229`
MD5	`e7d21c86aadf883e5670b0056deb0b96`
BLAKE2b-256	`b7a0d6013499b3c70243a4324b0a1e4751c2ae9f54ff94fba315e5044cd5c17e`

See more details on using hashes here.

File details

Details for the file mode-1.1.1-py2.py3-none-any.whl.

File metadata

Download URL: mode-1.1.1-py2.py3-none-any.whl
Upload date: Oct 25, 2017
Size: 46.0 kB
Tags: Python 2, Python 3
Uploaded using Trusted Publishing? No

File hashes

Hashes for mode-1.1.1-py2.py3-none-any.whl
Algorithm	Hash digest
SHA256	`8bd10d6a8023a565602b099f52162366a1311db201d903b953ea0e88b58eb705`
MD5	`ba1a1137f41d6016edeefebf5975639c`
BLAKE2b-256	`e01a2df658af1c35781725f16202d101142dd8b510871a35a3d6bf56ba6bc57b`