事件存储api的python http客户端
geteventstore的Python项目详细描述
版权所有（c）2017 Victor A.Martinez Santiago
包括但不限于使用、复制、修改、合并、发布、分发、再授权和/或出售软件副本的权利，以及允许向其提供软件的人这样做的权利，受限于以下条件：
对于适销性的保证，
适用于特定目的和不侵权。在任何情况下，
作者或版权所有人都不对任何索赔、损害赔偿或其他
责任负责，无论是在诉讼或合同、侵权行为或其他方面，都是由于，
与软件无关或与软件有关，或与
软件中的使用或其他交易有关。
说明：geteventstore
这是http接口的事件存储客户端的简单实现。它使用异步解析事件
\35；引用
>访问事件存储
\35；\35；客户端
创建一个新的事件大客户端。关键字参数是：
`host'：rethinkdb实例的宿主。默认值为"localhost"。
"port"：驱动程序端口，默认值为"2113"。
"loop"：异步事件循环，默认值为"asyncio.get"u event loop（）`
*示例*：为默认事件存储创建新客户端loop=asyncio.get/event/u loop（）
client=geteventstore.client（loop=loop）
``
`client.stream'u reader（选项）->；reader
创建流读取器。关键字参数是：
`stream'：要读取的流。
*example*：创建新的流读取器
``python
import geteventstore
import asyncio
async def test（loop）：
尝试：
current=0
poll=10
当为true时：
current=await get new events（loop，current，轮询）
键盘中断除外：
返回
poll=0）：
client=geteventstore.client（loop=loop）
reader=client.stream/reader（传单）
reader.next version=current
if poll>；0:
reader.long poll（poll）
在读卡器中更新：
print（event）
print（metadata）
print（updated）
return reader.next version
if
name==``main user'
loop=asyncio.get-u event loop（）
loop.run to complete（测试（循环）
`
\35；\35；reader
>；reader
关键字参数是：
`stream'：要从
`client'读取的流：geteventstore client
`feed'u parser:要使用的feed parser，默认为'feed parser'。必须与feedparser兼容
`http://client才能使用，默认为'aiohttp'。鼠标t与aiohttp兼容
*示例*：创建一个新流并从*text*
`` python
import geteventstore
import asyncio
async def test（loop）：
尝试：
当前=0
轮询=10
为真时：
当前=等待获取事件（循环、当前、轮询）
键盘中断除外：
返回
=geteventstore.client（loop=loop）
reader=geteventstore.reader（'flyers'，client）
reader.next_version=current
if poll>；0:
reader.long椆poll（poll）
async for event，在reader中更新：
print（event.id）
print（updated）
返回读卡器。下一个版本
待办事项：
-[-]从流中读取
-[x]捕获订阅
-[x]易失订阅
-[]持久订阅
-[x]写入流
平台：未知
包括但不限于使用、复制、修改、合并、发布、分发、再授权和/或出售软件副本的权利，以及允许向其提供软件的人这样做的权利，受限于以下条件：
对于适销性的保证，
适用于特定目的和不侵权。在任何情况下，
作者或版权所有人都不对任何索赔、损害赔偿或其他
责任负责，无论是在诉讼或合同、侵权行为或其他方面，都是由于，
与软件无关或与软件有关，或与
软件中的使用或其他交易有关。
说明：geteventstore
这是http接口的事件存储客户端的简单实现。它使用异步解析事件
\35；引用
>访问事件存储
\35；\35；客户端
创建一个新的事件大客户端。关键字参数是：
`host'：rethinkdb实例的宿主。默认值为"localhost"。
"port"：驱动程序端口，默认值为"2113"。
"loop"：异步事件循环，默认值为"asyncio.get"u event loop（）`
*示例*：为默认事件存储创建新客户端loop=asyncio.get/event/u loop（）
client=geteventstore.client（loop=loop）
``
`client.stream'u reader（选项）->；reader
创建流读取器。关键字参数是：
`stream'：要读取的流。
*example*：创建新的流读取器
``python
import geteventstore
import asyncio
async def test（loop）：
尝试：
current=0
poll=10
当为true时：
current=await get new events（loop，current，轮询）
键盘中断除外：
返回
poll=0）：
client=geteventstore.client（loop=loop）
reader=client.stream/reader（传单）
reader.next version=current
if poll>；0:
reader.long poll（poll）
在读卡器中更新：
print（event）
print（metadata）
print（updated）
return reader.next version
if
name==``main user'
loop=asyncio.get-u event loop（）
loop.run to complete（测试（循环）
`
\35；\35；reader
>；reader
关键字参数是：
`stream'：要从
`client'读取的流：geteventstore client
`feed'u parser:要使用的feed parser，默认为'feed parser'。必须与feedparser兼容
`http://client才能使用，默认为'aiohttp'。鼠标t与aiohttp兼容
*示例*：创建一个新流并从*text*
`` python
import geteventstore
import asyncio
async def test（loop）：
尝试：
当前=0
轮询=10
为真时：
当前=等待获取事件（循环、当前、轮询）
键盘中断除外：
返回
=geteventstore.client（loop=loop）
reader=geteventstore.reader（'flyers'，client）
reader.next_version=current
if poll>；0:
reader.long椆poll（poll）
async for event，在reader中更新：
print（event.id）
print（updated）
返回读卡器。下一个版本
待办事项：
-[-]从流中读取
-[x]捕获订阅
-[x]易失订阅
-[]持久订阅
-[x]写入流
平台：未知
欢迎加入QQ群-->： 979659372
