Skip to content
Create a gist now

Instantly share code, notes, and snippets.

Embed URL


Subversion checkout URL

You can clone with
Download ZIP
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
Something went wrong with that request. Please try again.