Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
Perform secondary index (2i) searches on Twitter hashtags stored in Riak and count the matching tags.
import riak
Riak = riak.RiakClient(pb_port=10017, protocol='pbc')
TweetsBucket = Riak.bucket('tweets')
results = TweetsBucket.get_index("hashtags_bin", "android",
"androie", return_terms=True)
count = {}
# Thanks to return_terms=True, each result will be a tuple: matched
# index term and associated Riak key
for item in results.results:
hashtag = item[0]
if hashtag in count:
count[hashtag] += 1
count[hashtag] = 1
print count
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment