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

updating data model

Browse Source
This commit is contained in:
Jonathan Branan
2024-08-15 15:34:42 -05:00
parent ba40fc92af
commit 5dc12d6c23
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
inexDataModel.py
View File

@@ -15,7 +15,7 @@ def dataTemplate(transactionType,**kwargs):
}, },
"guid": kwargs.get('guid'), "guid": kwargs.get('guid'),
"node_name": kwargs.get('node_name'), "node_name": kwargs.get('node_name'),
"prd_ext_tenant_id": kwargs.get('tenant'), "prd_ext_tenant_id": kwargs.get('prd_ext_tenant_id'),
"product_name": "GlobalScape EFT", "product_name": "GlobalScape EFT",
"prd_ext_tenant_name": "GlobalScape EFT", "prd_ext_tenant_name": "GlobalScape EFT",
"classifications": [{ "classifications": [{
@@ -58,7 +58,7 @@ def dataTemplate(transactionType,**kwargs):
"time": kwargs.get('time'), "time": kwargs.get('time'),
}], }],
"prd_ext_tenant_name": "Globalscape EFT", "prd_ext_tenant_name": "Globalscape EFT",
"prd_ext_tenant_id": kwargs.get('tenant'), "prd_ext_tenant_id": kwargs.get('prd_ext_tenant_id'),
"product_name": "Globalscape EFT", "product_name": "Globalscape EFT",
"session": { "session": {
"created_time": kwargs.get('time'), "created_time": kwargs.get('time'),
@@ -96,7 +96,7 @@ def dataTemplate(transactionType,**kwargs):
"type": kwargs.get('dst_endpoint_type') "type": kwargs.get('dst_endpoint_type')
}, },
"guid": kwargs.get('guid'), "guid": kwargs.get('guid'),
"prd_ext_tenant_id": kwargs.get('tenant'), "prd_ext_tenant_id": kwargs.get('prd_ext_tenant_id'),
"product_name": "GlobalScape EFT", "product_name": "GlobalScape EFT",
"prd_ext_tenant_name": "GlobalScape EFT", "prd_ext_tenant_name": "GlobalScape EFT",
"src_endpoint": { "src_endpoint": {

2
inexDataProcessing.py
View File

@@ -9,7 +9,6 @@ def processData(data, template, **kwargs):
# print(f'Row: {row}') # print(f'Row: {row}')
if identifyUtype(row.get('Command')) == "other": if identifyUtype(row.get('Command')) == "other":
continue continue
if row.get('Command') == None: if row.get('Command') == None:
continue continue
try: try:
@@ -51,6 +50,7 @@ def processData(data, template, **kwargs):
if row.get('TransactionGUID') not in transactionLoginid: if row.get('TransactionGUID') not in transactionLoginid:
try: try:
processedData.append(template(identifyUtype(row.get('TransactionObject')),\ processedData.append(template(identifyUtype(row.get('TransactionObject')),\
prd_ext_tenant_id=kwargs.get('prd_ext_tenant_id'),\
guid=row.get('TransactionGUID'),\ guid=row.get('TransactionGUID'),\
prd_instance_id=kwargs.get('prd_instance_id'),\ prd_instance_id=kwargs.get('prd_instance_id'),\
product_guid=kwargs.get('product_guid'),\ product_guid=kwargs.get('product_guid'),\