A Ruby client for the Cassandra distributed database.
Supports 1.8.7, 1.9.2, and rubinius on Cassandra 0.6.13, 0.7.9, 0.8.6, 1.0.0-rc2, 1.1.5.
Here is a quick sample of the general use (more details in Read/Write API below):
require 'cassandra'
client = Cassandra.new('Twitter', '127.0.0.1:9160')
client.insert(:Users, "5", {'screen_name' => "buttonscat"})
Copyright 2009-2011 Twitter, Inc. See included LICENSE file. Portions copyright 2004-2009 David Heinemeier Hansson, and used with permission.
The Cassandra project is under very active development, and as such there are a few different versions that you may need to use this gem with. We have set up an easy sure fire mechanism for selecting the specific version that you are connecting to while requiring the gem.
The default version is the currently stable release of cassandra. (0.8 at this time.)
To use the default version simply use a normal require:
require 'cassandra'
To use a specific version (1.0 in this example) you would use a slightly differently formatted require:
require 'cassandra/1.0'
These mechanisms work well when you are using the cassandra gem in your own projects or irb, but if you would rather not hard code your app to a specific version you can always specify an environment variable with the version you are using:
export CASSANDRA_VERSION=0.8
Then you would use the default require as listed above:
require 'cassandra'
This is the main method used to insert rows into cassandra. If the column_family that you are inserting into is a SuperColumnFamily then the hash passed in should be a nested hash, otherwise it should be a flat hash.
This method can also be called while in batch mode. If in batch mode then we queue up the mutations (an insert in this case) and pass them to cassandra in a single batch at the end of the block.
Example:
@client.insert(:Statuses, key, {'body' => 'v', 'user' => 'v'})
columns = {@uuids[1] => 'v1', @uuids[2] => 'v2'}
@client.insert(:StatusRelationships, key, {'user_timelines' => columns})
This method is used to delete (actually marking them as deleted with a tombstone) rows, columns, or super columns depending on the parameters passed. If only a key is passed the entire row will be marked as deleted. If a column name is passed in that column will be deleted.
Example:
@client.insert(:Statuses, key, {'body' => 'v', 'subject' => 'v'})
@client.remove(:Statuses, key, 'body') # removes the 'body' column
@client.remove(:Statuses, key) # removes the row
Count the columns for the provided parameters.
Example:
@client.insert(:Statuses, key, {'body' => 'v1', 'user' => 'v2'})
@client.count_columns(:Statuses, key) # returns 2
Return a hash (actually, a Cassandra::OrderedHash) or a single value representing the element at the column_family:key:[column]:[sub_column] path you request.
Example:
@client.insert(:Users, key, {'body' => 'v', 'user' => 'v'})
@client.get(:Users, key)) # returns {'body' => 'v', 'user' => 'v'}
Multi-key version of Cassandra#get.
This method allows you to select multiple rows with a single query. If a key that is passed in doesn't exist an empty hash will be returned.
Supports the same parameters as Cassandra#get.
Example:
@client.insert(:Users, '1', {'body' => 'v1', 'user' => 'v1'})
@client.insert(:Users, '2', {'body' => 'v2', 'user' => 'v2'})
expected = OrderedHash[
'1', {'body' => 'v1', 'user' => 'v1'},
'2', {'body' => 'v2', 'user' => 'v2'},
'bogus', {}
]
result = @client.multi_get(:Users, ['1', '2', 'bogus'])
Return true if the column_family:key:[column]:[sub_column] path you request exists.
If passed in only a row key it will query for any columns (limiting to 1) for that row key. If a column is passed in it will query for that specific column/super column.
This method will return true or false.
Example:
@client.insert(:Statuses, 'key', {'body' => 'v'})
@client.exists?(:Statuses, 'key') # returns true
@client.exists?(:Statuses, 'bogus') # returns false
@client.exists?(:Statuses, 'key', 'body') # returns true
@client.exists?(:Statuses, 'key', 'bogus') # returns false
Return an Cassandra::OrderedHash containing the columns specified for the given range of keys in the column_family you request.
This method is just a convenience wrapper around Cassandra#get_range_single and Cassandra#get_range_batch. If :key_size, :batch_size, or a block is passed in Cassandra#get_range_batch will be called. Otherwise Cassandra#get_range_single will be used.
The start_key and finish_key parameters are only useful for iterating of all records as is done in the Cassandra#each and Cassandra#each_key methods if you are using the RandomPartitioner.
If the table is partitioned with OrderPreservingPartitioner you may use the start_key and finish_key params to select all records with the same prefix value.
If a block is passed in we will yield the row key and columns for each record returned.
Please note that Cassandra returns a row for each row that has existed in the system since gc_grace_seconds. This is because deleted row keys are marked as deleted, but left in the system until the cluster has had resonable time to replicate the deletion. This function attempts to suppress deleted rows (actually any row returned without columns is suppressed).
Example:
10.times do |i|
@client.insert(:Statuses, i.to_s, {'body' => '1'})
end
@client.get_range_keys(:Statuses, :key_count => 4)
# returns:
#{
# '0' => {'body' => '1'},
# '1' => {'body' => '1'},
# '2' => {'body' => '1'},
# '3' => {'body' => '1'}
#}
Return an Array containing all of the keys within a given range.
This method just calls Cassandra#get_range and returns the row keys for the records returned.
See Cassandra#get_range for options.
Return an Array containing all of the keys within a given range.
This method just calls Cassandra#get_range and returns the row keys for the records returned.
See Cassandra#get_range for options.
Iterate through each key within the given range parameters. This function can be used to iterate over each key in the given column family.
This method just calls Cassandra#get_range and yields each row key.
See Cassandra#get_range for options.
Example: 10.times do |i| @client.insert(:Statuses, k + i.to_s, {"body-#{i.to_s}" => 'v'}) end
@client.each_key(:Statuses) do |key|
print key
end
# returns 0123456789
Iterate through each row within the given column_family.
This method just calls Cassandra#get_range and yields the key and columns.
See Cassandra#get_range for options.
This method is used to query a secondary index with a set of provided search parameters
Please note that you can either specify a CassandraThrift::IndexClause or an array of hashes with the format as below.
Example:
@client.create_index('Twitter', 'Statuses', 'x', 'LongType')
@client.insert(:Statuses, 'row1', { 'x' => [0,10].pack("NN") })
(2..10).to_a.each do |i|
@twitter.insert(:Statuses, 'row' + i.to_s, { 'x' => [0,20].pack("NN"), 'non_indexed' => [i].pack('N*') })
end
@client.insert(:Statuses, 'row11', { 'x' => [0,30].pack("NN") })
expressions = [{:column_name => 'x', :value => [0,20].pack("NN"), :comparison => "=="}]
# verify multiples will be returned
@client.get_indexed_slices(:Statuses, expressions).length # returns 9
# verify that GT and LT queries perform properly
expressions = [
{ :column_name => 'x',
:value => [0,20].pack("NN"),
:comparison => "=="},
{ :column_name => 'non_indexed',
:value => [5].pack("N*"),
:comparison => ">"}
]
@client.get_indexed_slices(:Statuses, expressions).length # returns 5
Takes a block where all the mutations (inserts and deletions) inside it are queued, and at the end of the block are passed to cassandra in a single batch.
If you don't want to send all the mutations inside the block in a big single batch, you can use the :queue_size option to send smaller batches. If the queue is not empty at the end of the block, the remaining mutations are sent.
Example:
@client.batch do
@client.insert(:Statuses, 'k1', {'body' => 'v1'})
@client.insert(:Statuses, 'k2', {'body' => 'v2'})
@client.remove(:Statuses, 'k3')
end
The Github issue tracker is here. If you have problems with this library or Cassandra itself, please use the cassandra-user mailing list.
FAQs
Unknown package
We found that sessionm-cassandra demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 3 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
In this segment of the Risky Business podcast, Feross Aboukhadijeh and Patrick Gray discuss the challenges of tracking malware discovered in open source softare.
Research
Security News
A threat actor's playbook for exploiting the npm ecosystem was exposed on the dark web, detailing how to build a blockchain-powered botnet.
Security News
NVD’s backlog surpasses 20,000 CVEs as analysis slows and NIST announces new system updates to address ongoing delays.