output record TS

ColumbiaDVMM · Oct 9, 2019 · 3182560 · 3182560
1 parent 3825cc8
commit 3182560
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/cufacesearch/cufacesearch/ingester/kinesis_ingester.py b/cufacesearch/cufacesearch/ingester/kinesis_ingester.py
@@ -271,8 +271,9 @@ def get_msg_json(self):
  if self.verbose > 5:
  #msg = "[{}: log] Found message at SequenceNumber {} in shard {}: {}"
  #print(msg.format(self.pp, sqn, sh_id, rec_json))
- msg = "[{}: log] Found message at SequenceNumber {} in shard {}"
- print(msg.format(self.pp, sqn, sh_id))
+ rec_ts = rec['ApproximateArrivalTimestamp']
+ msg = "[{}: log] Found message at SequenceNumber {} and timestamp {} in shard {}"
+ print(msg.format(self.pp, sqn, rec_ts, sh_id))
 
  # Store `sqn`. Is there anything else we should store?
  # Maybe number of records read for sanity check