nameko-pony 1.2.5

Pony dependency for nameko services

nameko-pony

Pony dependency for nameko services

Installation

pip install nameko-pony

Usage

app.py

from nameko.rpc import rpc
from pony.orm import Database, Required
from nameko_pony import PonySession, db_session


db = Database()

class Person(db.Entity):
    name = Required(str)


class MyService(object):
    name = "my_service"

    pony_session = PonySession(db)

    @rpc
    def hello(self, name):
        with self.pony_session:
            Person(name=name)


    @rpc
    @db_session
    def world(self, name):
        Person(name=name)

config.yml

AMQP_URI: 'pyamqp://guest:guest@localhost'
DATABASE_URI: 'sqlite:///:memory:'
# DATABASE_URI: 'mysql://usr:pwd@localhost/db_name'