code: def _batch_insert(self, inserts, intervals, **kwargs):
      '''
      Batch insert implementation.
      '''
      updates = {}
      # TODO support flush interval
      for interval,config in self._intervals.items():
        for timestamp,names in inserts.iteritems():
          timestamps = self._normalize_timestamps(timestamp, intervals, config)
          for name,values in names.iteritems():
            for value in values:
              for tstamp in timestamps:
                query,insert = self._insert_data(
                  name, value, tstamp, interval, config, dry_run=True)
  
                batch_key = self._batch_key(query)
                updates.setdefault(batch_key, {'query':query, 'interval':interval})
                new_insert = self._batch(insert, updates[batch_key].get('insert'))
                updates[batch_key]['insert'] = new_insert
  
      # now that we've collected a bunch of updates, flush them out
      for spec in updates.values():
        self._client[ spec['interval'] ].update(
          spec['query'], spec['insert'], upsert=True, check_keys=False f _batch_insert(self, inserts, intervals, **kwargs):
      '''
      Batch insert implementation.
      '''
      updates = {}
      # TODO support flush interval
      for interval,config in self._intervals.items():
        for timestamp,names in inserts.iteritems():
          timestamps = self._normalize_timestamps(timestamp, intervals, config)
          for name,values in names.iteritems():
            for value in values:
              for tstamp in timestamps:
                query,insert = self._insert_data(
                  name, value, tstamp, interval, config, dry_run=True)
  
                batch_key = self._batch_key(query)
                updates.setdefault(batch_key, {'query':query, 'interval':interval})
                new_insert = self._batch(insert, updates[batch_key].get('insert'))
                updates[batch_key]['insert'] = new_insert
  
      # now that we've collected a bunch of updates, flush them out
      for spec in updates.values():
        self._client[ spec['interval'] ].update(
          spec['query'], spec['insert'], upsert=True, check_keys=False )
docs: Batch insert implementation.