Skip to content

@macintux /2i.py
Created

Embed URL

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Perform secondary index (2i) searches on Twitter hashtags stored in Riak and count the matching tags.
#!/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
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.