Perform secondary index (2i) searches on Twitter hashtags stored in Riak and count the matching tags.

2i.py

#!/usr/local/bin/python

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
    else:
        count[hashtag] = 1

print count