Sha256: e2f232e3c266af9304357e3cbae9300de7531616c55d238ef7b37355cc273eaa
Contents?: true
Size: 1.8 KB
Versions: 11
Compression:
Stored size: 1.8 KB
Contents
# Mongoid and Elasticsearch # ========================= # # http://mongoid.org/en/mongoid/index.html $LOAD_PATH.unshift File.expand_path('../../lib', __FILE__) require 'pry' Pry.config.history.file = File.expand_path('../../tmp/elasticsearch_development.pry', __FILE__) require 'benchmark' require 'logger' require 'ansi/core' require 'mongoid' require 'elasticsearch/model' require 'elasticsearch/model/callbacks' Mongoid.logger.level = Logger::DEBUG Moped.logger.level = Logger::DEBUG Mongoid.connect_to 'articles' Elasticsearch::Model.client = Elasticsearch::Client.new host: 'localhost:9250', log: true class Article include Mongoid::Document field :id, type: String field :title, type: String field :published_at, type: DateTime attr_accessible :id, :title, :published_at if respond_to? :attr_accessible def as_indexed_json(options={}) as_json(except: [:id, :_id]) end end # Extend the model with Elasticsearch support # Article.__send__ :include, Elasticsearch::Model # Article.__send__ :include, Elasticsearch::Model::Callbacks # Store data # Article.delete_all Article.create id: '1', title: 'Foo' Article.create id: '2', title: 'Bar' Article.create id: '3', title: 'Foo Foo' # Index data # client = Elasticsearch::Client.new host:'localhost:9250', log:true client.indices.delete index: 'articles' rescue nil client.bulk index: 'articles', type: 'article', body: Article.all.map { |a| { index: { _id: a.id, data: a.attributes } } }, refresh: true # puts Benchmark.realtime { 9_875.times { |i| Article.create title: "Foo #{i}" } } puts '', '-'*Pry::Terminal.width! response = Article.search 'foo'; Pry.start(binding, prompt: lambda { |obj, nest_level, _| '> ' }, input: StringIO.new('response.records.to_a'), quiet: true)
Version data entries
11 entries across 11 versions & 2 rubygems