建立图表以处理流

emit的Python项目详细描述


emit是一个用于实时数据处理的python库。它可以分配工作 用CeleryRQcoordinate execution in other languages,让你挥杆 以泰山式的精度从你的图形树中提取。

尝一尝:

fromemitimportrouterrouter=Router()@router.node(['word'],entry_point=True)defparse_document(msg):forwordinmsg.document.strip().split(' '):yieldword@router.node(['word','count'],'parse_document')defcount_word(msg):returnmsg.word,redis.zincrby('word_counts',msg.word,1)importrandomdocument='the words in this document will be counted and emitted by count_word'.split(' ')router(document=' '.join(random.choice(document)foriinrange(20)))

那你是怎么得到的?在皮皮上!

pip install emit

一些链接:

支持的Python:

  • cpython 2.6
  • cpython 2.7
  • cpython 3.2
  • cpython 3.3(目前芹菜除外)
  • Pypy 1.9

从源/开发分支安装:

emit的发布相当频繁,因此您应该很好地使用 版本。但是,如果需要当前不在版本中的内容,请尝试 develop分支:

pip install git+git://github.com/BrianHicks/emit.git@develop

只是要被警告事情会破裂。一定要检查Travis看看你想要的平台是不是 正在通过。应该是,但也许不是。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
Java中的模板类   java如何创建跨服务域模型映射?   java如何最好地指定与Netty一起使用的Protobuf(最好使用内置Protobuf支持)   java Android Studio计数器文本视图字段未更新   操作属性>添加更改侦听器上的java按钮   Android中JSON参数的java解析   java DynamoDB和全局二级索引和ObjectMapper   JVM的Xmx限制的java外部控制?   java如何在触摸事件中停止图像滑块的自动滚动   java如何在AEM中从/content/dam读取xml文件?   在创建JavaNIO文件系统时,“env”选项(及其用途)是什么?   java如何在jdk 7或更早版本中使用lambda表达式   使用Java清理CSS