【发布时间】:2014-05-06 17:06:05
【问题描述】:
我正在尝试学习有关大数据的教程,它想从使用 cqlsh 定义的键空间中读取数据。
这段代码我已经编译成功了:
require 'rubygems'
require 'cassandra'
db = Cassandra.new('big_data', '127.0.0.1:9160')
# get a specific user's tags
row = db.get(:user_tags,"paul")
###
def tag_counts_from_row(row)
tags = {}
row.each_pair do |pair|
column, tag_count = pair
#tag_name = column.parts.first
tag_name = column
tags[tag_name] = tag_count
end
tags
end
###
# insert a new user
db.add(:user_tags, "todd", 3, "postgres")
db.add(:user_tags, "lili", 4, "win")
tags = tag_counts_from_row(row)
puts "paul - #{tags.inspect}"
但是当我写这部分来输出每个人的标签时,我得到了一个错误。
user_ids = []
db.get_range(:user_tags, :batch_size => 10000) do |id|
# user_ids << id
end
rows_with_ids = db.multi_get(:user_tags, user_ids)
rows_with_ids.each do |row_with_id|
name, row = row_with_id
tags = tag_counts_from_row(row)
puts "#{name} - #{tags.inspect}"
end
错误是:
第 33 行:警告:块参数的多个值(2 代表 1)
我认为错误可能来自不兼容的 Cassandra 和 Ruby 版本。如何解决?
【问题讨论】: