jblu/Inex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases 8 Wiki Activity

updating processData

Browse Source
This commit is contained in:
Jonathan Branan 2024-07-16 23:47:15 -05:00
parent bf5a45bb20
commit 7b3e5ab327
2 changed files with 35 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
README.md
View File

@ -1,3 +1,34 @@
# Inex # Inex
Information Exchange - Pull data from EFT ARM then dump it to a json file Information Exchange - Pull data from EFT ARM then dump it to a json file
# Data Map:
## tbl_ProtocolCommands
- ProtocolCommandID
- Time_stamp
- RemoteIP
- RemotePort
- LocalIP
- LocalPort
- Protocol
- SiteName
- Command
- CommandParameters
- FileName
- VirtualFolderName
- PhysicalFolderName
- IsInternal
- FileSize
- TransferTime
- BytesTransferred
- ResultID
- TransactionID
- Description
- Actor
## tbl_Transactions
- TransactionID
- ParentTransactionID
- TransactionObject
- TransactionGUID
- NodeName
- time_stamp

6
inexDataProcessing.py
View File

@ -9,19 +9,19 @@ def processData(data, template):
file_path=row.get('PhysicalFolderName'),\ file_path=row.get('PhysicalFolderName'),\
file_virtual_path=row.get('VirtualFolderName'),\ file_virtual_path=row.get('VirtualFolderName'),\
file_name=row.get('FileName'),\ file_name=row.get('FileName'),\
guid=row.get(''),\ guid=row.get('TransactionGUID'),\
ref_id=row.get('ProtocolCommandID'),\ ref_id=row.get('ProtocolCommandID'),\
prd_instance_id=row.get(''),\ prd_instance_id=row.get(''),\
product_guid=row.get(''),\ product_guid=row.get(''),\
product_name=row.get(''),\ product_name=row.get(''),\
product_version=row.get(''),\ product_version=row.get(''),\
node_name=row.get(''),\ node_name=row.get('NodeName'),\
src_endpoint_port=row.get('RemotePort'),\ src_endpoint_port=row.get('RemotePort'),\
src_endpoint_ip=row.get('RemoteIP'),\ src_endpoint_ip=row.get('RemoteIP'),\
dst_endpoint_port=row.get('LocalPort'),\ dst_endpoint_port=row.get('LocalPort'),\
dst_endpoint_ip=row.get('LocalIP'),\ dst_endpoint_ip=row.get('LocalIP'),\
dst_endpoint_type=row.get('Protocol'),\ dst_endpoint_type=row.get('Protocol'),\
session_uid=row.get(''),\ session_uid=row.get('TransactionID'),\
bytes_out=row.get('BytesTransferred'),\ bytes_out=row.get('BytesTransferred'),\
transfer_time=row.get('TransferTime'),\ transfer_time=row.get('TransferTime'),\
time=row.get('Time_stamp'),\ time=row.get('Time_stamp'),\