2024-07-15 22:32:42 -05:00
|
|
|
def processData(data, template):
|
|
|
|
|
processedData = []
|
|
|
|
|
for row in data:
|
|
|
|
|
# print(f'Row: {row}')
|
|
|
|
|
processedData.append(template(status=row.get(''),\
|
|
|
|
|
status_detail=row.get(''),\
|
|
|
|
|
status_code=row.get('ResultID'),\
|
|
|
|
|
file_size=row.get('FileSize'),\
|
|
|
|
|
file_path=row.get('PhysicalFolderName'),\
|
|
|
|
|
file_virtual_path=row.get('VirtualFolderName'),\
|
|
|
|
|
file_name=row.get('FileName'),\
|
2024-07-16 23:47:15 -05:00
|
|
|
guid=row.get('TransactionGUID'),\
|
2024-07-15 22:32:42 -05:00
|
|
|
ref_id=row.get('ProtocolCommandID'),\
|
|
|
|
|
prd_instance_id=row.get(''),\
|
|
|
|
|
product_guid=row.get(''),\
|
|
|
|
|
product_name=row.get(''),\
|
|
|
|
|
product_version=row.get(''),\
|
2024-07-16 23:47:15 -05:00
|
|
|
node_name=row.get('NodeName'),\
|
2024-07-15 22:32:42 -05:00
|
|
|
src_endpoint_port=row.get('RemotePort'),\
|
|
|
|
|
src_endpoint_ip=row.get('RemoteIP'),\
|
|
|
|
|
dst_endpoint_port=row.get('LocalPort'),\
|
|
|
|
|
dst_endpoint_ip=row.get('LocalIP'),\
|
|
|
|
|
dst_endpoint_type=row.get('Protocol'),\
|
2024-07-16 23:47:15 -05:00
|
|
|
session_uid=row.get('TransactionID'),\
|
2024-07-15 22:32:42 -05:00
|
|
|
bytes_out=row.get('BytesTransferred'),\
|
|
|
|
|
transfer_time=row.get('TransferTime'),\
|
|
|
|
|
time=row.get('Time_stamp'),\
|
|
|
|
|
user_type=row.get(''),\
|
|
|
|
|
user_domain=row.get('SiteName'),\
|
|
|
|
|
user_name=row.get('Actor'),\
|
|
|
|
|
utype=row.get('Command')))
|
|
|
|
|
return processedData
|
