happybase write hbase

happybase_write.py

# frontera hbase backend _schedule()

table = self.connection.table(self.table_name)
with table.batch(transaction=True) as b:
  for rk, tuples in six.iteritems(data):
    obj = dict()
    for score, item in tuples:
      column = 'f:%0.3f_%0.3f' % get_interval(score, 0.001)
      obj.setdefault(column, []).append(item)
    
    final = dict()
    from msgpack import Packer
    packer = Packer()
    for column, items in six.iteritems(obj):
      from io import BytesIO
      stream = BytesIO()
      for item in items:
        stream.write(packer.pack(item))
      final[column] = stream.getvalue()
    final[b'f:t'] = str(timestamp)
    b.put(rk, final)