def update_agg()

in src/lambda/StreamingIngestAggFeatures/lambda_function.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

def update_agg(fg_name, cc_num, avg_amt_last_10m, num_trans_last_10m):
    record = [{'FeatureName':'cc_num', 'ValueAsString': str(cc_num)},
              {'FeatureName':'avg_amt_last_10m', 'ValueAsString': str(avg_amt_last_10m)},
              {'FeatureName':'num_trans_last_10m', 'ValueAsString': str(num_trans_last_10m)},
              {'FeatureName':'trans_time', 'ValueAsString': str(int(round(time.time())))} #datetime.now().isoformat()} #
             ]
    sm_fs.put_record(FeatureGroupName=fg_name, Record=record)
    return