Added support for multiple vservers

kcantrel · kcantrel · commit d368a148730f · 2025-03-07T09:50:00.000-06:00
diff --git a/Monitoring/ingest_nas_audit_logs_into_cloudwatch/ingest_audit_log.py b/Monitoring/ingest_nas_audit_logs_into_cloudwatch/ingest_audit_log.py
@@ -389,7 +389,10 @@ def lambda_handler(event, context):     # pylint: disable=W0613
                             #
                             # Process the file.
                             processFile(fsxn, headersDownload, volumeUUID, filePath)
-                            lastFileRead[fsxn] = {vserverName: getEpoch(filePath)}
+                            if lastFileRead.get(fsxn) is None:
+                                lastFileRead[fsxn] = {vserverName: getEpoch(filePath)}
+                            else:
+                                lastFileRead[fsxn][vserverName] = getEpoch(filePath)
                             s3Client.put_object(Key=config['statsName'], Bucket=config['s3BucketName'], Body=json.dumps(lastFileRead).encode('UTF-8'))
                 #
                 # Get the next set of SVMs.

Original file line number	Diff line number	Diff line change
`@@ -389,7 +389,10 @@ def lambda_handler(event, context): # pylint: disable=W0613`
`389`	`389`	`#`
`390`	`390`	`# Process the file.`
`391`	`391`	`processFile(fsxn, headersDownload, volumeUUID, filePath)`
`392`		`- lastFileRead[fsxn] = {vserverName: getEpoch(filePath)}`
	`392`	`+ if lastFileRead.get(fsxn) is None:`
	`393`	`+ lastFileRead[fsxn] = {vserverName: getEpoch(filePath)}`
	`394`	`+ else:`
	`395`	`+ lastFileRead[fsxn][vserverName] = getEpoch(filePath)`
`393`	`396`	`s3Client.put_object(Key=config['statsName'], Bucket=config['s3BucketName'], Body=json.dumps(lastFileRead).encode('UTF-8'))`
`394`	`397`	`#`
`395`	`398`	`# Get the next set of SVMs.`