Create a gist now

Instantly share code, notes, and snippets.

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