Introduction
neo4apis is a ruby gem for building objects which import data into neo4j. It takes care of batching of queries for better import performance and creating indexes for better query performance. It also uses MERGEs to make sure the same node/relationship isn’t imported twice. neo4apis is for anybody who want to build a gem or even just an adapter in their application which encapsulates the logic of data import from some source. For examples see the drivers for Twitter and GitHub
In the below example we assume that a variable awesome_client is passed in which allows us to make requests to the API. This may be, for example, provided by another gem.
To install
gem 'neo4apis' in your Gemfile or gem install neo4apis
To use
“by require ‘neo4apis’
module Neo4Apis class AwesomeSite < Base # Adds a prefix to labels so that they become AwesomeSiteUser and AwesomeSiteWidget (optional) prefix :AwesomeSite
# Number of queries which are built up until batch request to DB is made (optional, default = 500)
batch_size 2000
uuid :User, :id
uuid :Widget, :uuid
def import_widget_search(*args)
@client.widget_search(*args).each do |widget|
add_widget(widget)
end
end
importer :Widget do |widget|
user_node = add_user(widget.owner)
# add_node comes from From Neo4Apis::Base
# Imports the uuid and text values from the widget object to the node
node = add_node(:Widget, widget, [:uuid, :text]) do |node|
# Imports the double_foo property to the node which isn't a simple copy
node.double_foo = widget.foo * 2
end
# add_relationship comes from Neo4Apis::Base
add_relationship(:owns, user_node, node)
node
end
importer :User do |user|
add_node :User, user, [:id, :username, :name]
end
end
end
“
Then somebody else could use your gem in the following manner:
“by
neo4j_session = Neo4j::Session.open # From the neo4j-core gem awesome_client = Awesome.open # From a theoretical API wrapping gem
neo4apis_awesome = Neo4Apis::AwesomeSite.new(neo4j_session)
neo4apis_awesome.batch do awesome_client.widget_search(‘cool’).each do |widget| neo4apis_awesome.import :Widget, widget # import is provided by neo4apis end end
“