asyncio Server-Sent Events实现
项目描述
SSE
===
Simple asyncio/aiohttp包装器,用于Server-Sent Events。
使用方法
-----
发送事件
```python
import asyncio
import sse
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
yield from asyncio.sleep(2)
self.send('foo')
yield from asyncio.sleep(2)
self.send('bar', event='wakeup')
start_server = sse.serve(Handler, 'localhost', 8888)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
```
验证传入请求
```python
class Handler(sse.Handler)
def validate_sse(self)
super().validate_sse()
# use self.request / self.payload
if not self.request.path.startswith('/live')
raise sse.SseException()
```
发送JSON数据
```python
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
self.send({'foo': 'bar'})
```
发送ID / 事件名称 / 重试信息
```python
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
self.send('some data', id=12345, event='something', retry=10000)
```
===
Simple asyncio/aiohttp包装器,用于Server-Sent Events。
使用方法
-----
发送事件
```python
import asyncio
import sse
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
yield from asyncio.sleep(2)
self.send('foo')
yield from asyncio.sleep(2)
self.send('bar', event='wakeup')
start_server = sse.serve(Handler, 'localhost', 8888)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
```
验证传入请求
```python
class Handler(sse.Handler)
def validate_sse(self)
super().validate_sse()
# use self.request / self.payload
if not self.request.path.startswith('/live')
raise sse.SseException()
```
发送JSON数据
```python
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
self.send({'foo': 'bar'})
```
发送ID / 事件名称 / 重试信息
```python
class Handler(sse.Handler)
@asyncio.coroutine
def handle_request(self)
self.send('some data', id=12345, event='something', retry=10000)
```
项目详情
下载文件
为您的平台下载文件。如果您不确定要选择哪个,请了解更多关于 安装包 的信息。
源代码分发
asyncio-sse-0.1.tar.gz (3.9 kB 查看哈希值)
构建分发
asyncio_sse-0.1-py33-none-any.whl (5.2 kB 查看哈希值)
关闭
asyncio-sse-0.1.tar.gz 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | abba9240f92fbf69617e4865cd7dafda9bd38265d2f9447970a34f6945076acf |
|
MD5 | 009303177d457ce017aed73fc4a01b33 |
|
BLAKE2b-256 | 74a7af14384cd397dab9619441cbaf974c19838b1df88f278f531d6979d5e749 |
关闭
asyncio_sse-0.1-py33-none-any.whl 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 81cf9757e023c91998f8243fa5db1632eb8d0174a6c9da466c085345a603e1c8 |
|
MD5 | cf013e44169fbfd4e02cc9e9ffc31567 |
|
BLAKE2b-256 | 3b314a319452374caa3d16c44ee16ae33df0cf1a8de4683a8d73e135d7317f9c |