'Record an occurence of an item in a distinct counter.'

def record_multi(self, items, timestamp=None):

    if (timestamp is None):
        timestamp = timezone.now()
    ts = int(to_timestamp(timestamp))
    with self.cluster.fanout() as client:
        for (model, key, values) in items:
            c = client.target_key(key)
            for (rollup, max_values) in six.iteritems(self.rollups):
                k = self.make_key(model, rollup, ts, key)
                c.pfadd(k, *values)
                c.expireat(k, self.calculate_expiry(rollup, max_values, timestamp))
