建立图表以处理流

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程序输出问题   使用全新Spring上下文的java启动JUnit测试   oauth获取Java中Microsoft Graph API的令牌   java如何停止声音   for loop Java 8向集合中添加自定义元素的方法?   java如何将数组的第n个值赋给变量   java局部变量在使用前必须初始化,例如实例变量,没有这样的限制,为什么?   macos在Mac上安装和运行Java应用程序   运行jar文件时发生java NoClassDefFoundError   用于映射同一数据库中多个MySQL表的java Hibernate配置文件(.cfg.xml)?   如何使用Java通过代理发送华为推送通知   datetime Java将MessagePack时间戳转换为日期   java如何从读取器返回的字符串中删除unicode空格。readLine()   java返回Ljava的字符串值。lang.对象   如何使用java方法在jsp中打印arraylist   JAVAutil。扫描器java。lang.NumberFormatException与一个只有int的txt文件   java Dijkstra单调路径   键入错误号时发生java错误