rails应用中各数据平台的对接
2024-08-31 02:48:51
1.mongo
#Gemfile添加如下两个gem包
gem 'mongoid', '~> 5.1.0'
gem 'mongo', '~> 2.4’
@client = Mongo::Client.new([host1,host2],:database=>'database_name',:user=>"user_name",:password=>"password")
@db = @client[:database_name].database
@collection_names = @db.collection_names
@collection_names.each do |collection_name|
i=0
@db[collection_name.to_sym].find.each do |x|
puts x
i = i + 1
break if i == 10
end
end
2.redis
$redis = Redis.new(:host => "host", :port => 6379, :db => 2, :password=>"password")
$redis.keys
3.elasticsearch
gem 'elasticsearch'
gem 'elasticsearch-rails'
gem 'elasticsearch-model'
$elastic = Elasticsearch::Client.new hosts: [{ host: 'host1',port: '9200',user: 'elastic',password: 'password'},{host: 'host1',port: '9200',user: 'elastic',password: 'password'}], randomize_hosts: true, log: false,send_get_body_as: "post"
Elasticsearch::Model.client = $elastic
$elastic.search index:"index_name"
4.kafka
gem 'ruby-kafka', '~> 0.5.0'
kafka = Kafka.new(seed_brokers:["host:9092"])
consumer = kafka.consumer(:group_id=>"100")
consumer.subscribe("topic_name")
i=0
consumer.each_message do |meg|
puts i=i+1
puts meg.value
break if i==10
end
最新文章
- ibatis 和 mybatis
- Android中如何控制元素的显示隐藏?
- 学习 Local Sensitive Hash
- 功能源代码(扇形进度)及Delegate运用在开放事件中、UINavigationController的封装
- SaltStack配置管理之状态模块和jinja2(五)
- wireshark使用教程
- setsockopt的作用
- Spark核心概念之RDD
- switchover步骤切换
- ISA中的WEB链
- angularJS看MVVM
- C#常用的数据格式转换
- css01
- ASP.Net Core WebApi几种版本控制对比
- Team Foundation Server 2015 Update 2.1 发布日志
- Http的定义及其基本概念介绍
- Nginx——使用 Nginx 提升网站访问速度【转载+整理】
- Docker第一个应用:Hello World
- jdk与eclipse不匹配的各种问题。。。
- 【题解】【LibreOJ Round #6】花团 LOJ 534 时间线段树分治 背包
热门文章
- W3School学习网站
- Mac终端下 连接 ubuntu 16.04 ssh root@*.*.*.* permission denied 问题解决方案
- easyui学习笔记6—基本的Accordion(手风琴)
- 程序中实现两个DataTable的Left Join效果(修改了,网上第二个DataTable为空,所处的异常)
- Java---页面之间传值跳转
- Linux 学习总结(五)-linux 文件系统及相关命令
- 学会WCF之试错法——超时
- Selenium基础知识(8大元素定位概说)
- 十八、IntelliJ IDEA 常用快捷键 之 Windows 版
- 【题解】洛谷P4180 [BJWC2010] 严格次小生成树(最小生成树+倍增求LCA)