streamsets_javascript_evaluator_code_1.js

var records = sdc.records;
for(var i = 0; i < records.length; i++) {
    try {
      var documentMap = {};
      documentMap["drone_id"] = records[i].value['drone_id'];
      documentMap["event_time"] = records[i].value['event_time'];
      documentMap["phase"] = records[i].value['phase'];
      documentMap["altitude"] = records[i].value['altitude'];
      documentMap["latitude"] = records[i].value['latitude'];
      documentMap["longitude"] = records[i].value['longitude'];
      documentMap["speed"] = records[i].value['speed'];
      documentMap["heading"] = records[i].value['heading'];

      var insertOneMap = {'insertOne': {'document':documentMap}}
      records[i].value['insertOne'] = insertOneMap;
      
      var newRecord = sdc.createRecord(records[i].sourceId + '-insertOne');
      var newRecordFields = sdc.createMap(false);
      newRecord.value = insertOneMap;
      sdc.output.write(newRecord);
    } catch (e) {
      // Send record to error
      sdc.error.write(records[i], e);
    }
}