-
- GitHub
- GitLab
- Bitbucket
-
By logging in you accept
our terms of service
and privacy policy
SDP: Subscription Data Protocol
pip install subsdata==0.1.2
import asyncio
import websockets
from rethinkdb import r
from subsdata.sdp import sdp, method, sub, get_connection, is_logged, has_role
@method
@is_logged
async def add(user, a, b):
return a + b
@method
@has_role('admin')
async def create(user):
connection = await get_connection()
await r.table('test').insert({'x': 0}).run(connection)
@method
async def increment(user, id, value):
connection = await get_connection()
await r.table('test').get(id).update({"x": r.row["x"]+value}).run(connection)
@sub
def x_less_than(user, max):
return r.table('test').filter(lambda row: (row['x'] < max))
def main():
loop = asyncio.get_event_loop()
loop.run_until_complete(websockets.serve(sdp, '0.0.0.0', 8888))
print("Real time server started at port 8888")
loop.run_forever()
loop.close()
#example of a docker-compose.yml
version: '3'
services:
ws:
build: .
stdin_open: true
tty: true
ports:
- "8888:8888"
volumes:
- ./:/usr/src/app
environment:
- RT=rdb
- DEBUG=1
- SECRET=secret
command: python -m watchgod app.main
rdb:
image: rethinkdb
ports:
- "8080:8080"
- "28015:28015"
volumes:
- './data:/data'
The Tidelift Subscription provides access to a continuously curated stream of human-researched and maintainer-verified data on open source packages and their licenses, releases, vulnerabilities, and development practices.
Learn more →Something wrong with this page? Make a suggestion
Export .ABOUT file for this package
Last synced: 2021-02-22 08:35:23 UTC
Login to resync this project