文件名称：turbine:Ruby的容错多线程流处理
文件大小：34KB
文件格式：ZIP
更新时间：2024-06-04 11:03:45
Ruby
Ruby的容错多线程流处理。 Turbine是基于Zookeeper构建的面向性能的流处理库。 它目前支持Kafka作为消息队列，但是被设计为可插入的，以便将来可能支持其他消息队列。 涡轮机不是工作队列，并且缺少您希望通过工作队列获得的大多数功能。 涡轮机设计为小型，简单和快速。 安装 将这些行添加到应用程序的Gemfile中： gem "turbine" 然后执行： $ bundle 或将其自己安装为： $ gem install turbine 入门 请参阅Wiki上的“ ，以获取有关使用Turbine编写第一个流处理作业的快速教程。 用法 目前，Turbine支持使用 gem从Kafka消息队列中进行流处理，该gem实现了自平衡消费者组。 要为主题创建新的Kafka使用者，请执行以下操作： require "turbine" require "turbine/
【文件预览】：
turbine-master
----.gitignore(107B)
----Guardfile(223B)
----turbine.png(17KB)
----.rspec(46B)
----bin()
--------setup(95B)
--------console(332B)
----.travis.yml(381B)
----.rubocop.yml(220B)
----CODE_OF_CONDUCT.md(1KB)
----LICENSE.txt(1KB)
----spec()
--------turbine()
--------turbine_spec.rb(133B)
--------spec_helper.rb(159B)
----README.md(4KB)
----lib()
--------turbine()
--------turbine.rb(292B)
----Gemfile(179B)
----turbine.gemspec(1KB)
----Rakefile(153B)
----tasks()
--------rubocop.rake(50B)
--------kafka.rake(29B)
--------rspec.rake(58B)
--------zookeeper.rake(2KB)