diff --git a/collectors/aws/accessanalyzer/listFindings.js b/collectors/aws/accessanalyzer/listFindings.js
index 10c9cb933b..decc88253a 100644
--- a/collectors/aws/accessanalyzer/listFindings.js
+++ b/collectors/aws/accessanalyzer/listFindings.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AccessAnalyzer
+} = require('@aws-sdk/client-accessanalyzer');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var accessanalyzer = new AWS.AccessAnalyzer(AWSConfig);
+    var accessanalyzer = new AccessAnalyzer(AWSConfig);
     async.eachLimit(collection.accessanalyzer.listAnalyzers[AWSConfig.region].data, 15, function(analyzer, cb) {
         collection.accessanalyzer.listFindings[AWSConfig.region][analyzer.arn] = {};
         var params = {
diff --git a/collectors/aws/apigateway/getClientCertificate.js b/collectors/aws/apigateway/getClientCertificate.js
index 06f3c0b0d2..0c7f5f5e28 100644
--- a/collectors/aws/apigateway/getClientCertificate.js
+++ b/collectors/aws/apigateway/getClientCertificate.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    APIGateway
+} = require('@aws-sdk/client-api-gateway');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var apigateway = new AWS.APIGateway(AWSConfig);
+    var apigateway = new APIGateway(AWSConfig);
 
     async.eachLimit(collection.apigateway.getRestApis[AWSConfig.region].data, 5, function(api, cb){
         if (!collection.apigateway.getStages ||
diff --git a/collectors/aws/apigateway/getIntegration.js b/collectors/aws/apigateway/getIntegration.js
index dc7a737c45..fcdbe2bcbd 100644
--- a/collectors/aws/apigateway/getIntegration.js
+++ b/collectors/aws/apigateway/getIntegration.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    APIGateway
+} = require('@aws-sdk/client-api-gateway');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var apigateway = new AWS.APIGateway(AWSConfig);
+    var apigateway = new APIGateway(AWSConfig);
 
     async.eachLimit(collection.apigateway.getRestApis[AWSConfig.region].data, 5, function(api, cb){
         if (!collection.apigateway.getResources ||
diff --git a/collectors/aws/appmesh/describeVirtualGateway.js b/collectors/aws/appmesh/describeVirtualGateway.js
index 2bcb597458..f9dc10bd68 100644
--- a/collectors/aws/appmesh/describeVirtualGateway.js
+++ b/collectors/aws/appmesh/describeVirtualGateway.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AppMesh
+} = require('@aws-sdk/client-app-mesh');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var appmesh = new AWS.AppMesh(AWSConfig);
+    var appmesh = new AppMesh(AWSConfig);
 
     if (!collection.appmesh ||
         !collection.appmesh.listMeshes ||
diff --git a/collectors/aws/autoscaling/describeLaunchConfigurations.js b/collectors/aws/autoscaling/describeLaunchConfigurations.js
index 55bb0adf0a..0d26617fd1 100644
--- a/collectors/aws/autoscaling/describeLaunchConfigurations.js
+++ b/collectors/aws/autoscaling/describeLaunchConfigurations.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AutoScaling
+} = require('@aws-sdk/client-auto-scaling');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var autoscaling = new AWS.AutoScaling(AWSConfig);
+    var autoscaling = new AutoScaling(AWSConfig);
 
     async.eachLimit(collection.autoscaling.describeAutoScalingGroups[AWSConfig.region].data, 15, function(asg, cb){
         collection.autoscaling.describeLaunchConfigurations[AWSConfig.region][asg.AutoScalingGroupARN] = {};
diff --git a/collectors/aws/autoscaling/describeNotificationConfigurations.js b/collectors/aws/autoscaling/describeNotificationConfigurations.js
index 34e4adcb6d..94cf8dfd5f 100644
--- a/collectors/aws/autoscaling/describeNotificationConfigurations.js
+++ b/collectors/aws/autoscaling/describeNotificationConfigurations.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    AutoScaling
+} = require('@aws-sdk/client-auto-scaling');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var autoscaling = new AWS.AutoScaling(AWSConfig);
+    var autoscaling = new AutoScaling(AWSConfig);
 
     async.eachLimit(collection.autoscaling.describeAutoScalingGroups[AWSConfig.region].data, 15, function(asg, cb){        
         var params = {
diff --git a/collectors/aws/cloudfront/getDistribution.js b/collectors/aws/cloudfront/getDistribution.js
index 22df249208..104f3841e7 100644
--- a/collectors/aws/cloudfront/getDistribution.js
+++ b/collectors/aws/cloudfront/getDistribution.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudFront
+} = require('@aws-sdk/client-cloudfront');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudfront = new AWS.CloudFront(AWSConfig);
+    var cloudfront = new CloudFront(AWSConfig);
 
     async.eachLimit(collection.cloudfront.listDistributions[AWSConfig.region].data, 15, function(distribution, cb){        
         collection.cloudfront.getDistribution[AWSConfig.region][distribution.Id] = {};
diff --git a/collectors/aws/cloudtrail/listTags.js b/collectors/aws/cloudtrail/listTags.js
index dc3c2cbc9e..f6387f852e 100644
--- a/collectors/aws/cloudtrail/listTags.js
+++ b/collectors/aws/cloudtrail/listTags.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudTrail
+} = require('@aws-sdk/client-cloudtrail');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudtrail = new AWS.CloudTrail(AWSConfig);
+    var cloudtrail = new CloudTrail(AWSConfig);
 
     async.eachLimit(collection.cloudtrail.describeTrails[AWSConfig.region].data, 15, function(trail, cb) {
         var params = {
diff --git a/collectors/aws/cloudwatch/getEc2MetricStatistics.js b/collectors/aws/cloudwatch/getEc2MetricStatistics.js
index 3742ea8762..86672c94c0 100644
--- a/collectors/aws/cloudwatch/getEc2MetricStatistics.js
+++ b/collectors/aws/cloudwatch/getEc2MetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require('../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
 
     async.eachLimit(collection.ec2.describeInstances[AWSConfig.region].data, 10, function(reservation, cb) {
         reservation.Instances.forEach(instance => {
diff --git a/collectors/aws/cloudwatch/getEcMetricStatistics.js b/collectors/aws/cloudwatch/getEcMetricStatistics.js
index 68146f8c9a..a67c4cf332 100644
--- a/collectors/aws/cloudwatch/getEcMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getEcMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.elasticache.describeCacheClusters[AWSConfig.region].data, 10, function(cluster, cb){        
         collection.cloudwatch.getEcMetricStatistics[AWSConfig.region][cluster.CacheClusterId] = {};
diff --git a/collectors/aws/cloudwatch/getEsMetricStatistics.js b/collectors/aws/cloudwatch/getEsMetricStatistics.js
index 8bcc532c13..f86f3d1953 100644
--- a/collectors/aws/cloudwatch/getEsMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getEsMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.opensearch.listDomainNames[AWSConfig.region].data, 10, function(domain, cb){        
         collection.cloudwatch.getEsMetricStatistics[AWSConfig.region][domain.DomainName] = {};
diff --git a/collectors/aws/cloudwatch/getRdsMetricStatistics.js b/collectors/aws/cloudwatch/getRdsMetricStatistics.js
index 07754f026e..c77a42b509 100644
--- a/collectors/aws/cloudwatch/getRdsMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getRdsMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
diff --git a/collectors/aws/cloudwatch/getRdsReadIOPSMetricStatistics.js b/collectors/aws/cloudwatch/getRdsReadIOPSMetricStatistics.js
index abbdc2ef25..bf365e4581 100644
--- a/collectors/aws/cloudwatch/getRdsReadIOPSMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getRdsReadIOPSMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsReadIOPSMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
diff --git a/collectors/aws/cloudwatch/getRdsWriteIOPSMetricStatistics.js b/collectors/aws/cloudwatch/getRdsWriteIOPSMetricStatistics.js
index dc06cb6861..180773f943 100644
--- a/collectors/aws/cloudwatch/getRdsWriteIOPSMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getRdsWriteIOPSMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.rds.describeDBInstances[AWSConfig.region].data, 10, function(instance, cb){        
         collection.cloudwatch.getRdsWriteIOPSMetricStatistics[AWSConfig.region][instance.DBInstanceIdentifier] = {};
diff --git a/collectors/aws/cloudwatch/getredshiftMetricStatistics.js b/collectors/aws/cloudwatch/getredshiftMetricStatistics.js
index 1504781a36..e2d6a28901 100644
--- a/collectors/aws/cloudwatch/getredshiftMetricStatistics.js
+++ b/collectors/aws/cloudwatch/getredshiftMetricStatistics.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CloudWatch
+} = require('@aws-sdk/client-cloudwatch');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var cloudwatch = new AWS.CloudWatch(AWSConfig);
+    var cloudwatch = new CloudWatch(AWSConfig);
    
     async.eachLimit(collection.redshift.describeClusters[AWSConfig.region].data, 10, function(cluster, cb){        
         collection.cloudwatch.getredshiftMetricStatistics[AWSConfig.region][cluster.ClusterIdentifier] = {};
diff --git a/collectors/aws/codebuild/batchGetProjects.js b/collectors/aws/codebuild/batchGetProjects.js
index f3b9e0b8d9..76300aebaa 100644
--- a/collectors/aws/codebuild/batchGetProjects.js
+++ b/collectors/aws/codebuild/batchGetProjects.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    CodeBuild
+} = require('@aws-sdk/client-codebuild');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var codebuild = new AWS.CodeBuild(AWSConfig);
+    var codebuild = new CodeBuild(AWSConfig);
 
     async.eachLimit(collection.codebuild.listProjects[AWSConfig.region].data, 15, function(project, cb){
         collection.codebuild.batchGetProjects[AWSConfig.region][project] = {};
diff --git a/collectors/aws/collector.js b/collectors/aws/collector.js
index 6f7fa7b99a..c80e6efb78 100644
--- a/collectors/aws/collector.js
+++ b/collectors/aws/collector.js
@@ -16,15 +16,19 @@
  - callback: Function to call when the collection is complete
  *********************/
 
-var AWS = require('aws-sdk');
+
+const {
+    EC2
+} = require('@aws-sdk/client-ec2');
+
 var async = require('async');
-var https = require('https');
 var helpers = require(__dirname + '/../../helpers/aws');
 var collectors = require(__dirname + '/../../collectors/aws');
 var collectData = require(__dirname + '/../../helpers/shared.js');
-// Override max sockets
-var agent = new https.Agent({maxSockets: 100});
-AWS.config.update({httpOptions: {agent: agent}});
+
+const { Agent } = require('https');
+const { Agent: HttpAgent } = require("http");
+const { NodeHttpHandler } = require('@aws-sdk/node-http-handler');
 
 var rateError = {message: 'rate', statusCode: 429};
 
@@ -50,7 +54,12 @@ var collect = function(AWSConfig, settings, callback) {
     var AWSXRay;
     var debugMode = settings.debug_mode;
     if (debugMode) AWSXRay = require('aws-xray-sdk');
-
+    // Override max sockets
+    const customRequestHandler = new NodeHttpHandler({
+        httpsAgent: new Agent({maxSockets: 100}),
+        httpAgent: new HttpAgent({maxSockets: 100})
+    });
+    AWSConfig.requestHandler = customRequestHandler;
     AWSConfig.maxRetries = 8;
     AWSConfig.retryDelayOptions = {base: 100};
 
@@ -63,7 +72,8 @@ var collect = function(AWSConfig, settings, callback) {
 
     let runApiCalls = [];
 
-    var AWSEC2 = new AWS.EC2(AWSConfig);
+    var AWSEC2 = new EC2(AWSConfig);
+
     var params = {AllRegions: true};
     var excludeRegions = [];
 
@@ -136,7 +146,7 @@ var collect = function(AWSConfig, settings, callback) {
                             }
                         });
                     } else {
-                        var executor = debugMode ? (AWSXRay.captureAWSClient(new AWS[serviceName](LocalAWSConfig))) : new AWS[serviceName](LocalAWSConfig);
+                        var executor = debugMode ? (AWSXRay.captureAWSClient(new AWSXRay[serviceName](LocalAWSConfig))) : new AWSXRay[serviceName](LocalAWSConfig);
                         var paginating = false;
                         var executorCb = function(err, data) {
                             if (err) {
@@ -305,7 +315,7 @@ var collect = function(AWSConfig, settings, callback) {
                                     }
                                 });
                             } else {
-                                var executor = debugMode ? (AWSXRay.captureAWSClient(new AWS[serviceName](LocalAWSConfig))) : new AWS[serviceName](LocalAWSConfig);
+                                var executor = debugMode ? (AWSXRay.captureAWSClient(new AWSXRay[serviceName](LocalAWSConfig))) : new AWSXRay[serviceName](LocalAWSConfig);
 
                                 if (!collection[callObj.reliesOnService][callObj.reliesOnCall][LocalAWSConfig.region] ||
                                     !collection[callObj.reliesOnService][callObj.reliesOnCall][LocalAWSConfig.region].data) {
diff --git a/collectors/aws/collector_multipart.js b/collectors/aws/collector_multipart.js
index e9960d4aee..a4a5637f55 100644
--- a/collectors/aws/collector_multipart.js
+++ b/collectors/aws/collector_multipart.js
@@ -16,16 +16,19 @@
  - callback: Function to call when the collection is complete
  *********************/
 
-var AWS = require('aws-sdk');
+
+const {
+    EC2
+} = require('@aws-sdk/client-ec2');
+
 var async = require('async');
-var https = require('https');
 var helpers = require(__dirname + '/../../helpers/aws');
 var collectors = require(__dirname + '/../../collectors/aws');
 var collectData = require(__dirname + '/../../helpers/shared.js');
 
-// Override max sockets
-var agent = new https.Agent({maxSockets: 100});
-AWS.config.update({httpOptions: {agent: agent}});
+const { Agent } = require('https');
+const { Agent: HttpAgent } = require("http");
+const { NodeHttpHandler } = require('@aws-sdk/node-http-handler');
 
 var CALLS_CONFIG = {
     TOTAL_PARTS: 14,
@@ -61,7 +64,12 @@ var collect = function(AWSConfig, settings, callback) {
     var AWSXRay;
     var debugMode = settings.debug_mode;
     if (debugMode) AWSXRay = require('aws-xray-sdk');
-
+    // Override max sockets
+    const customRequestHandler = new NodeHttpHandler({
+        httpsAgent: new Agent({maxSockets: 100}),
+        httpAgent: new HttpAgent({maxSockets: 100})
+    });
+    AWSConfig.requestHandler = customRequestHandler;
     AWSConfig.maxRetries = 8;
     AWSConfig.retryDelayOptions = {base: 100};
 
@@ -80,7 +88,7 @@ var collect = function(AWSConfig, settings, callback) {
 
     let runApiCalls = [];
 
-    var AWSEC2 = new AWS.EC2(AWSConfig);
+    var AWSEC2 = new EC2(AWSConfig);
     var params = {AllRegions: true};
     var excludeRegions = [];
     var timeoutCheck;
@@ -165,7 +173,7 @@ var collect = function(AWSConfig, settings, callback) {
                             }
                         });
                     } else {
-                        var executor = debugMode ? (AWSXRay.captureAWSClient(new AWS[serviceName](LocalAWSConfig))) : new AWS[serviceName](LocalAWSConfig);
+                        var executor = debugMode ? (AWSXRay.captureAWSClient(new AWSXRay[serviceName](LocalAWSConfig))) : new AWSXRay[serviceName](LocalAWSConfig);
                         var paginating = false;
                         var executorCb = function(err, data) {
                             if (err) {
@@ -345,7 +353,7 @@ var collect = function(AWSConfig, settings, callback) {
                                 }
                             });
                         } else {
-                            var executor = debugMode ? (AWSXRay.captureAWSClient(new AWS[serviceName](LocalAWSConfig))) : new AWS[serviceName](LocalAWSConfig);
+                            var executor = debugMode ? (AWSXRay.captureAWSClient(new AWSXRay[serviceName](LocalAWSConfig))) : new AWSXRay[serviceName](LocalAWSConfig);
 
                             if (!collection[callObj.reliesOnService][callObj.reliesOnCall][LocalAWSConfig.region] ||
                                 !collection[callObj.reliesOnService][callObj.reliesOnCall][LocalAWSConfig.region].data) {
diff --git a/collectors/aws/connect/instanceAttachmentStorageConfigs.js b/collectors/aws/connect/instanceAttachmentStorageConfigs.js
index ef5b983ba2..e1929decca 100644
--- a/collectors/aws/connect/instanceAttachmentStorageConfigs.js
+++ b/collectors/aws/connect/instanceAttachmentStorageConfigs.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Connect
+} = require('@aws-sdk/client-connect');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var connect = new AWS.Connect(AWSConfig);
+    var connect = new Connect(AWSConfig);
 
     async.eachLimit(collection.connect.listInstances[AWSConfig.region].data, 15, function(instance, cb){
         collection.connect.instanceAttachmentStorageConfigs[AWSConfig.region][instance.Id] = {};
diff --git a/collectors/aws/connect/listInstanceCallRecordingStorageConfigs.js b/collectors/aws/connect/listInstanceCallRecordingStorageConfigs.js
index 6d24e6f137..71a3506045 100644
--- a/collectors/aws/connect/listInstanceCallRecordingStorageConfigs.js
+++ b/collectors/aws/connect/listInstanceCallRecordingStorageConfigs.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Connect
+} = require('@aws-sdk/client-connect');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var connect = new AWS.Connect(AWSConfig);
+    var connect = new Connect(AWSConfig);
 
     async.eachLimit(collection.connect.listInstances[AWSConfig.region].data, 15, function(instance, cb){
         collection.connect.listInstanceCallRecordingStorageConfigs[AWSConfig.region][instance.Id] = {};
diff --git a/collectors/aws/connect/listInstanceChatTranscriptStorageConfigs.js b/collectors/aws/connect/listInstanceChatTranscriptStorageConfigs.js
index 163f67c79c..d6431566ee 100644
--- a/collectors/aws/connect/listInstanceChatTranscriptStorageConfigs.js
+++ b/collectors/aws/connect/listInstanceChatTranscriptStorageConfigs.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Connect
+} = require('@aws-sdk/client-connect');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var connect = new AWS.Connect(AWSConfig);
+    var connect = new Connect(AWSConfig);
 
     async.eachLimit(collection.connect.listInstances[AWSConfig.region].data, 15, function(instance, cb){
         collection.connect.listInstanceChatTranscriptStorageConfigs[AWSConfig.region][instance.Id] = {};
diff --git a/collectors/aws/connect/listInstanceExportedReportStorageConfigs.js b/collectors/aws/connect/listInstanceExportedReportStorageConfigs.js
index 325536b259..95233218d5 100644
--- a/collectors/aws/connect/listInstanceExportedReportStorageConfigs.js
+++ b/collectors/aws/connect/listInstanceExportedReportStorageConfigs.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Connect
+} = require('@aws-sdk/client-connect');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var connect = new AWS.Connect(AWSConfig);
+    var connect = new Connect(AWSConfig);
 
     async.eachLimit(collection.connect.listInstances[AWSConfig.region].data, 15, function(instance, cb){
         collection.connect.listInstanceExportedReportStorageConfigs[AWSConfig.region][instance.Id] = {};
diff --git a/collectors/aws/connect/listInstanceMediaStreamStorageConfigs.js b/collectors/aws/connect/listInstanceMediaStreamStorageConfigs.js
index 0dd1323f52..4d6609415e 100644
--- a/collectors/aws/connect/listInstanceMediaStreamStorageConfigs.js
+++ b/collectors/aws/connect/listInstanceMediaStreamStorageConfigs.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Connect
+} = require('@aws-sdk/client-connect');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var connect = new AWS.Connect(AWSConfig);
+    var connect = new Connect(AWSConfig);
 
     async.eachLimit(collection.connect.listInstances[AWSConfig.region].data, 15, function(instance, cb){
         collection.connect.listInstanceMediaStreamStorageConfigs[AWSConfig.region][instance.Id] = {};
diff --git a/collectors/aws/dynamodb/describeContinuousBackups.js b/collectors/aws/dynamodb/describeContinuousBackups.js
index eb919126df..9f650ed105 100644
--- a/collectors/aws/dynamodb/describeContinuousBackups.js
+++ b/collectors/aws/dynamodb/describeContinuousBackups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    DynamoDB
+} = require('@aws-sdk/client-dynamodb');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var dynamodb = new AWS.DynamoDB(AWSConfig);
+    var dynamodb = new DynamoDB(AWSConfig);
 
     async.eachLimit(collection.dynamodb.listTables[AWSConfig.region].data, 15, function(table, cb){
         collection.dynamodb.describeContinuousBackups[AWSConfig.region][table] = {};
diff --git a/collectors/aws/dynamodb/describeTable.js b/collectors/aws/dynamodb/describeTable.js
index 1beeb3f4e4..95165ce3eb 100644
--- a/collectors/aws/dynamodb/describeTable.js
+++ b/collectors/aws/dynamodb/describeTable.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    DynamoDB
+} = require('@aws-sdk/client-dynamodb');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var dynamodb = new AWS.DynamoDB(AWSConfig);
+    var dynamodb = new DynamoDB(AWSConfig);
 
     async.eachLimit(collection.dynamodb.listTables[AWSConfig.region].data, 15, function(table, cb){
         collection.dynamodb.describeTable[AWSConfig.region][table] = {};
diff --git a/collectors/aws/dynamodb/listBackups.js b/collectors/aws/dynamodb/listBackups.js
index 67bd0c374f..6a8d87293b 100644
--- a/collectors/aws/dynamodb/listBackups.js
+++ b/collectors/aws/dynamodb/listBackups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    DynamoDB
+} = require('@aws-sdk/client-dynamodb');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var dynamodb = new AWS.DynamoDB(AWSConfig);
+    var dynamodb = new DynamoDB(AWSConfig);
 
     async.eachLimit(collection.dynamodb.listTables[AWSConfig.region].data, 15, function(table, cb){
         collection.dynamodb.listBackups[AWSConfig.region][table] = {};
diff --git a/collectors/aws/ec2/describeSnapshotAttribute.js b/collectors/aws/ec2/describeSnapshotAttribute.js
index a7a3577a78..6bb112e690 100644
--- a/collectors/aws/ec2/describeSnapshotAttribute.js
+++ b/collectors/aws/ec2/describeSnapshotAttribute.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EC2
+} = require('@aws-sdk/client-ec2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ec2 = new AWS.EC2(AWSConfig);
+    var ec2 = new EC2(AWSConfig);
 
     async.eachLimit(collection.ec2.describeSnapshots[AWSConfig.region].data, 20, function(snapshot, cb){
         collection.ec2.describeSnapshotAttribute[AWSConfig.region][snapshot.SnapshotId] = {};
diff --git a/collectors/aws/ec2/describeSnapshots.js b/collectors/aws/ec2/describeSnapshots.js
index 0cdf26ef13..ffe675df33 100644
--- a/collectors/aws/ec2/describeSnapshots.js
+++ b/collectors/aws/ec2/describeSnapshots.js
@@ -1,4 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EC2
+} = require('@aws-sdk/client-ec2');
+
+const {
+    STS
+} = require("@aws-sdk/client-sts");
+
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 // This call must be overridden because the
@@ -6,8 +13,8 @@ var helpers = require(__dirname + '/../../../helpers/aws');
 // available, including public ones
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ec2 = new AWS.EC2(AWSConfig);
-    var sts = new AWS.STS(AWSConfig);
+    var ec2 = new EC2(AWSConfig);
+    var sts = new STS(AWSConfig);
 
     helpers.makeCustomCollectorCall(sts, 'getCallerIdentity', {}, retries, null, null, null, function(stsErr, stsData) {
         if (stsErr || !stsData.Account) {
diff --git a/collectors/aws/ec2/describeSubnets.js b/collectors/aws/ec2/describeSubnets.js
index 766ba6e0a1..0604065cba 100644
--- a/collectors/aws/ec2/describeSubnets.js
+++ b/collectors/aws/ec2/describeSubnets.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EC2
+} = require('@aws-sdk/client-ec2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ec2 = new AWS.EC2(AWSConfig);
+    var ec2 = new EC2(AWSConfig);
 
     async.eachLimit(collection.ec2.describeVpcs[AWSConfig.region].data, 15, function(vpc, cb){
         collection.ec2.describeSubnets[AWSConfig.region][vpc.VpcId] = {};
diff --git a/collectors/aws/ecs/describeCluster.js b/collectors/aws/ecs/describeCluster.js
index 965206dbe3..7c6cb497ae 100644
--- a/collectors/aws/ecs/describeCluster.js
+++ b/collectors/aws/ecs/describeCluster.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachLimit(collection.ecs.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.ecs.describeCluster[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/ecs/describeContainerInstances.js b/collectors/aws/ecs/describeContainerInstances.js
index 8d0bdd4bdf..6b96cd7099 100644
--- a/collectors/aws/ecs/describeContainerInstances.js
+++ b/collectors/aws/ecs/describeContainerInstances.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachOfLimit(collection.ecs.listContainerInstances[AWSConfig.region], 10, function(containerInstanceData,instance, cb){
         async.eachLimit(containerInstanceData.data, 5, function(containerInstance, ccb){
diff --git a/collectors/aws/ecs/describeServices.js b/collectors/aws/ecs/describeServices.js
index 08773ec42b..b3d9e8403e 100644
--- a/collectors/aws/ecs/describeServices.js
+++ b/collectors/aws/ecs/describeServices.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachOfLimit(collection.ecs.listServices[AWSConfig.region], 10, function(servicesData,instance, cb){
         async.eachLimit(servicesData.data, 5, function(service, ccb){
diff --git a/collectors/aws/ecs/describeTasks.js b/collectors/aws/ecs/describeTasks.js
index cbe9e8e3e3..93194fc0fa 100644
--- a/collectors/aws/ecs/describeTasks.js
+++ b/collectors/aws/ecs/describeTasks.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachOfLimit(collection.ecs.listTasks[AWSConfig.region], 10, function(tasksData,instance, cb){
         async.eachLimit(tasksData.data, 5, function(task, ccb){
diff --git a/collectors/aws/ecs/listContainerInstances.js b/collectors/aws/ecs/listContainerInstances.js
index 987ca65d2b..39bdbacc86 100644
--- a/collectors/aws/ecs/listContainerInstances.js
+++ b/collectors/aws/ecs/listContainerInstances.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachLimit(collection.ecs.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.ecs.listContainerInstances[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/ecs/listServices.js b/collectors/aws/ecs/listServices.js
index 916ab9002d..f5ee6c16c9 100644
--- a/collectors/aws/ecs/listServices.js
+++ b/collectors/aws/ecs/listServices.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachLimit(collection.ecs.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.ecs.listServices[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/ecs/listTasks.js b/collectors/aws/ecs/listTasks.js
index aee40fe258..1cae69b40a 100644
--- a/collectors/aws/ecs/listTasks.js
+++ b/collectors/aws/ecs/listTasks.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ECS
+} = require('@aws-sdk/client-ecs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.ECS(AWSConfig);
+    var ecs = new ECS(AWSConfig);
 
     async.eachLimit(collection.ecs.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.ecs.listTasks[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/eks/describeCluster.js b/collectors/aws/eks/describeCluster.js
index e5e485badc..c8c4be8e10 100644
--- a/collectors/aws/eks/describeCluster.js
+++ b/collectors/aws/eks/describeCluster.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EKS
+} = require('@aws-sdk/client-eks');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var eks = new AWS.EKS(AWSConfig);
+    var eks = new EKS(AWSConfig);
 
     async.eachLimit(collection.eks.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.eks.describeCluster[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/eks/describeNodegroups.js b/collectors/aws/eks/describeNodegroups.js
index bba92226ef..c98d2769f1 100644
--- a/collectors/aws/eks/describeNodegroups.js
+++ b/collectors/aws/eks/describeNodegroups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EKS
+} = require('@aws-sdk/client-eks');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var eks = new AWS.EKS(AWSConfig);
+    var eks = new EKS(AWSConfig);
     //var autoscaling = new AWS.AutoScaling(AWSConfig);
 
     async.eachLimit(collection.eks.listClusters[AWSConfig.region].data, 5, function(cluster, cb){
diff --git a/collectors/aws/eks/listNodegroups.js b/collectors/aws/eks/listNodegroups.js
index 3679225bfb..e0582e7b5d 100644
--- a/collectors/aws/eks/listNodegroups.js
+++ b/collectors/aws/eks/listNodegroups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EKS
+} = require('@aws-sdk/client-eks');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var eks = new AWS.EKS(AWSConfig);
+    var eks = new EKS(AWSConfig);
 
     async.eachLimit(collection.eks.listClusters[AWSConfig.region].data, 10, function(cluster, cb){
         collection.eks.listNodegroups[AWSConfig.region][cluster] = {};
diff --git a/collectors/aws/elasticache/describeCacheSubnetGroups.js b/collectors/aws/elasticache/describeCacheSubnetGroups.js
index c9439edbac..bfc975c66f 100644
--- a/collectors/aws/elasticache/describeCacheSubnetGroups.js
+++ b/collectors/aws/elasticache/describeCacheSubnetGroups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElastiCache
+} = require('@aws-sdk/client-elasticache');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elasticache = new AWS.ElastiCache(AWSConfig);
+    var elasticache = new ElastiCache(AWSConfig);
 
     async.eachLimit(collection.elasticache.describeCacheClusters[AWSConfig.region].data, 15, function(cluster, cb){
         collection.elasticache.describeCacheSubnetGroups[AWSConfig.region][cluster.CacheSubnetGroupName] = {};
diff --git a/collectors/aws/elasticbeanstalk/describeConfigurationSettings.js b/collectors/aws/elasticbeanstalk/describeConfigurationSettings.js
index 287476cd50..7aa5b76717 100644
--- a/collectors/aws/elasticbeanstalk/describeConfigurationSettings.js
+++ b/collectors/aws/elasticbeanstalk/describeConfigurationSettings.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticBeanstalk
+} = require('@aws-sdk/client-elastic-beanstalk');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elasticbeanstalk = new AWS.ElasticBeanstalk(AWSConfig);
+    var elasticbeanstalk = new ElasticBeanstalk(AWSConfig);
 
     async.eachLimit(collection.elasticbeanstalk.describeEnvironments[AWSConfig.region].data, 15, function(environment, cb) {
         var params = {
diff --git a/collectors/aws/elb/describeInstanceHealth.js b/collectors/aws/elb/describeInstanceHealth.js
index 862c3a6ed3..1f57a4064e 100644
--- a/collectors/aws/elb/describeInstanceHealth.js
+++ b/collectors/aws/elb/describeInstanceHealth.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancing
+} = require('@aws-sdk/client-elastic-load-balancing');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELB(AWSConfig);
+    var elb = new ElasticLoadBalancing(AWSConfig);
 
     async.eachLimit(collection.elb.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elb.describeInstanceHealth[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/elb/describeLoadBalancerAttributes.js b/collectors/aws/elb/describeLoadBalancerAttributes.js
index 480267a287..8753127110 100644
--- a/collectors/aws/elb/describeLoadBalancerAttributes.js
+++ b/collectors/aws/elb/describeLoadBalancerAttributes.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancing
+} = require('@aws-sdk/client-elastic-load-balancing');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELB(AWSConfig);
+    var elb = new ElasticLoadBalancing(AWSConfig);
 
     async.eachLimit(collection.elb.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elb.describeLoadBalancerAttributes[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/elb/describeLoadBalancerPolicies.js b/collectors/aws/elb/describeLoadBalancerPolicies.js
index 8540fe804e..70b1ae8dc7 100644
--- a/collectors/aws/elb/describeLoadBalancerPolicies.js
+++ b/collectors/aws/elb/describeLoadBalancerPolicies.js
@@ -1,11 +1,16 @@
 // TODO: re-visit this one
 
-var AWS = require('aws-sdk');
+
+
+const {
+    ElasticLoadBalancing
+} = require('@aws-sdk/client-elastic-load-balancing');
+
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELB(AWSConfig);
+    var elb = new ElasticLoadBalancing(AWSConfig);
 
     // Gather list of policies from load balancers
     var policies = [];
diff --git a/collectors/aws/elb/describeTags.js b/collectors/aws/elb/describeTags.js
index a26db66f81..d8a39e202e 100644
--- a/collectors/aws/elb/describeTags.js
+++ b/collectors/aws/elb/describeTags.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancing
+} = require('@aws-sdk/client-elastic-load-balancing');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELB(AWSConfig);
+    var elb = new ElasticLoadBalancing(AWSConfig);
 
     async.eachLimit(collection.elb.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elb.describeTags[AWSConfig.region][lb.LoadBalancerName] = {};
diff --git a/collectors/aws/elbv2/describeListeners.js b/collectors/aws/elbv2/describeListeners.js
index 7ab5d6f0b9..c61b1fab82 100644
--- a/collectors/aws/elbv2/describeListeners.js
+++ b/collectors/aws/elbv2/describeListeners.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancingV2
+} = require('@aws-sdk/client-elastic-load-balancing-v2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELBv2(AWSConfig);
+    var elb = new ElasticLoadBalancingV2(AWSConfig);
 
     async.eachLimit(collection.elbv2.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elbv2.describeListeners[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/elbv2/describeLoadBalancerAttributes.js b/collectors/aws/elbv2/describeLoadBalancerAttributes.js
index 330020ff88..f3aa752a54 100644
--- a/collectors/aws/elbv2/describeLoadBalancerAttributes.js
+++ b/collectors/aws/elbv2/describeLoadBalancerAttributes.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancingV2
+} = require('@aws-sdk/client-elastic-load-balancing-v2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELBv2(AWSConfig);
+    var elb = new ElasticLoadBalancingV2(AWSConfig);
 
     async.eachLimit(collection.elbv2.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elbv2.describeLoadBalancerAttributes[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/elbv2/describeTags.js b/collectors/aws/elbv2/describeTags.js
index b15b568f6a..ea3831e1cb 100644
--- a/collectors/aws/elbv2/describeTags.js
+++ b/collectors/aws/elbv2/describeTags.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancingV2
+} = require('@aws-sdk/client-elastic-load-balancing-v2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELBv2(AWSConfig);
+    var elb = new ElasticLoadBalancingV2(AWSConfig);
 
     async.eachLimit(collection.elbv2.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elbv2.describeTags[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/elbv2/describeTargetGroups.js b/collectors/aws/elbv2/describeTargetGroups.js
index 2194a937cb..db751f3dce 100644
--- a/collectors/aws/elbv2/describeTargetGroups.js
+++ b/collectors/aws/elbv2/describeTargetGroups.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ElasticLoadBalancingV2
+} = require('@aws-sdk/client-elastic-load-balancing-v2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var elb = new AWS.ELBv2(AWSConfig);
+    var elb = new ElasticLoadBalancingV2(AWSConfig);
 
     async.eachLimit(collection.elbv2.describeLoadBalancers[AWSConfig.region].data, 15, function(lb, cb){
         collection.elbv2.describeTargetGroups[AWSConfig.region][lb.DNSName] = {};
diff --git a/collectors/aws/emr/describeSecurityConfiguration.js b/collectors/aws/emr/describeSecurityConfiguration.js
index c3b8760520..5e8b231ae7 100644
--- a/collectors/aws/emr/describeSecurityConfiguration.js
+++ b/collectors/aws/emr/describeSecurityConfiguration.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    EMR
+} = require('@aws-sdk/client-emr');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var emr = new AWS.EMR(AWSConfig);
+    var emr = new EMR(AWSConfig);
 
     async.eachLimit(collection.emr.listClusters[AWSConfig.region].data, 15, function(cluster, cb){
         if (!collection.emr.describeCluster ||
diff --git a/collectors/aws/firehose/describeDeliveryStream.js b/collectors/aws/firehose/describeDeliveryStream.js
index 0ad2541dcd..a36e901252 100644
--- a/collectors/aws/firehose/describeDeliveryStream.js
+++ b/collectors/aws/firehose/describeDeliveryStream.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Firehose
+} = require('@aws-sdk/client-firehose');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var firehose = new AWS.Firehose(AWSConfig);
+    var firehose = new Firehose(AWSConfig);
 
     async.eachLimit(collection.firehose.listDeliveryStreams[AWSConfig.region].data, 15, function(deliverystream, cb){
         collection.firehose.describeDeliveryStream[AWSConfig.region][deliverystream] = {};
diff --git a/collectors/aws/guardduty/describePublishingDestination.js b/collectors/aws/guardduty/describePublishingDestination.js
index 9a4ee1cb55..555a75c47b 100644
--- a/collectors/aws/guardduty/describePublishingDestination.js
+++ b/collectors/aws/guardduty/describePublishingDestination.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
 
     if (!collection.guardduty ||
         !collection.guardduty.listDetectors ||
diff --git a/collectors/aws/guardduty/getDetector.js b/collectors/aws/guardduty/getDetector.js
index e19098d888..ffdece566e 100644
--- a/collectors/aws/guardduty/getDetector.js
+++ b/collectors/aws/guardduty/getDetector.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
     async.eachLimit(collection.guardduty.listDetectors[AWSConfig.region].data, 15, function(detectorId, cb) {
         collection.guardduty.getDetector[AWSConfig.region][detectorId] = {};
         var params = {
diff --git a/collectors/aws/guardduty/getFindings.js b/collectors/aws/guardduty/getFindings.js
index c8b1a2e1f7..aca7007e80 100644
--- a/collectors/aws/guardduty/getFindings.js
+++ b/collectors/aws/guardduty/getFindings.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
     async.eachLimit(collection.guardduty.listDetectors[AWSConfig.region].data, 15, function(detectorId, dcb) {
         if (!collection.guardduty ||
             !collection.guardduty.listFindings ||
diff --git a/collectors/aws/guardduty/getMasterAccount.js b/collectors/aws/guardduty/getMasterAccount.js
index e24b7ad158..391babf757 100644
--- a/collectors/aws/guardduty/getMasterAccount.js
+++ b/collectors/aws/guardduty/getMasterAccount.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
     async.eachLimit(collection.guardduty.listDetectors[AWSConfig.region].data, 15, function(detectorId, cb) {
         collection.guardduty.getMasterAccount[AWSConfig.region][detectorId] = {};
         var params = {
diff --git a/collectors/aws/guardduty/listFindings.js b/collectors/aws/guardduty/listFindings.js
index 48dd2183d0..028a5a174e 100644
--- a/collectors/aws/guardduty/listFindings.js
+++ b/collectors/aws/guardduty/listFindings.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
     async.eachLimit(collection.guardduty.listDetectors[AWSConfig.region].data, 15, function(detectorId, cb) {
         collection.guardduty.listFindings[AWSConfig.region][detectorId] = {};
         var params = {
diff --git a/collectors/aws/guardduty/listPublishingDestinations.js b/collectors/aws/guardduty/listPublishingDestinations.js
index 0b32d7466c..04fd389e9d 100644
--- a/collectors/aws/guardduty/listPublishingDestinations.js
+++ b/collectors/aws/guardduty/listPublishingDestinations.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    GuardDuty
+} = require('@aws-sdk/client-guardduty');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var guardduty = new AWS.GuardDuty(AWSConfig);
+    var guardduty = new GuardDuty(AWSConfig);
     async.eachLimit(collection.guardduty.listDetectors[AWSConfig.region].data, 15, function(detectorId, cb) {
         collection.guardduty.listPublishingDestinations[AWSConfig.region][detectorId] = {};
         var params = {
diff --git a/collectors/aws/iam/generateCredentialReport.js b/collectors/aws/iam/generateCredentialReport.js
index 4ee1fdb2f3..6e8c0fccaf 100644
--- a/collectors/aws/iam/generateCredentialReport.js
+++ b/collectors/aws/iam/generateCredentialReport.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     var generateCredentialReport = function(genCb) {
         iam.generateCredentialReport(function(err, data) {
diff --git a/collectors/aws/iam/getGroupPolicy.js b/collectors/aws/iam/getGroupPolicy.js
index 95b2512819..71218b3de5 100644
--- a/collectors/aws/iam/getGroupPolicy.js
+++ b/collectors/aws/iam/getGroupPolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     if (!collection.iam ||
         !collection.iam.listGroups ||
diff --git a/collectors/aws/iam/getInstanceProfile.js b/collectors/aws/iam/getInstanceProfile.js
index 453e2a78fa..e044e9de19 100644
--- a/collectors/aws/iam/getInstanceProfile.js
+++ b/collectors/aws/iam/getInstanceProfile.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     if (!collection.ec2 ||
         !collection.ec2.describeInstances ||
diff --git a/collectors/aws/iam/getPolicyVersion.js b/collectors/aws/iam/getPolicyVersion.js
index 0238ee7b73..a1adcf26c5 100644
--- a/collectors/aws/iam/getPolicyVersion.js
+++ b/collectors/aws/iam/getPolicyVersion.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     if (!collection.iam ||
         !collection.iam.listPolicies ||
diff --git a/collectors/aws/iam/getRolePolicy.js b/collectors/aws/iam/getRolePolicy.js
index 239d1e45a9..9ea4347a4f 100644
--- a/collectors/aws/iam/getRolePolicy.js
+++ b/collectors/aws/iam/getRolePolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     if (!collection.iam ||
         !collection.iam.listRoles ||
diff --git a/collectors/aws/iam/getUserPolicy.js b/collectors/aws/iam/getUserPolicy.js
index d40a3a20d9..97ecf9cec4 100644
--- a/collectors/aws/iam/getUserPolicy.js
+++ b/collectors/aws/iam/getUserPolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
 
     if (!collection.iam ||
         !collection.iam.listUsers ||
diff --git a/collectors/aws/iam/listRoles.js b/collectors/aws/iam/listRoles.js
index c16f2a5c49..10fa2e6bbc 100644
--- a/collectors/aws/iam/listRoles.js
+++ b/collectors/aws/iam/listRoles.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    IAM
+} = require('@aws-sdk/client-iam');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var iam = new AWS.IAM(AWSConfig);
+    var iam = new IAM(AWSConfig);
     collection.iam.listRoles[AWSConfig.region] = {};
     var params = {};
 
diff --git a/collectors/aws/kinesis/describeStream.js b/collectors/aws/kinesis/describeStream.js
index 81fc8c0e32..3a6ba9eae7 100644
--- a/collectors/aws/kinesis/describeStream.js
+++ b/collectors/aws/kinesis/describeStream.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Kinesis
+} = require('@aws-sdk/client-kinesis');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var kinesis = new AWS.Kinesis(AWSConfig);
+    var kinesis = new Kinesis(AWSConfig);
 
     async.eachLimit(collection.kinesis.listStreams[AWSConfig.region].data, 15, function(stream, cb){
         collection.kinesis.describeStream[AWSConfig.region][stream] = {};
diff --git a/collectors/aws/kms/getKeyPolicy.js b/collectors/aws/kms/getKeyPolicy.js
index 4e562042f3..1d97d3f8cb 100644
--- a/collectors/aws/kms/getKeyPolicy.js
+++ b/collectors/aws/kms/getKeyPolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    KMS
+} = require('@aws-sdk/client-kms');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var kms = new AWS.KMS(AWSConfig);
+    var kms = new KMS(AWSConfig);
 
     async.eachLimit(collection.kms.listKeys[AWSConfig.region].data, 15, function(key, cb){
         collection.kms.getKeyPolicy[AWSConfig.region][key.KeyId] = {};
diff --git a/collectors/aws/kms/listGrants.js b/collectors/aws/kms/listGrants.js
index 4272e478b5..c7b813d0ed 100644
--- a/collectors/aws/kms/listGrants.js
+++ b/collectors/aws/kms/listGrants.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    KMS
+} = require('@aws-sdk/client-kms');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var kms = new AWS.KMS(AWSConfig);
+    var kms = new KMS(AWSConfig);
     async.eachLimit(collection.kms.listKeys[AWSConfig.region].data, 15, function(key, cb) {
         collection.kms.listGrants[AWSConfig.region][key.KeyId] = {};
         var params = {
diff --git a/collectors/aws/lexmodelsv2/describeBotAlias.js b/collectors/aws/lexmodelsv2/describeBotAlias.js
index fb6c951af8..855d4bf4e9 100644
--- a/collectors/aws/lexmodelsv2/describeBotAlias.js
+++ b/collectors/aws/lexmodelsv2/describeBotAlias.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    LexModelsV2
+} = require('@aws-sdk/client-lex-models-v2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var lexmodelsv2 = new AWS.LexModelsV2(AWSConfig);
+    var lexmodelsv2 = new LexModelsV2(AWSConfig);
 
     if (!collection.lexmodelsv2 ||
         !collection.lexmodelsv2.listBots ||
diff --git a/collectors/aws/lookoutvision/describeModel.js b/collectors/aws/lookoutvision/describeModel.js
index c22ac371f6..c168debd5f 100644
--- a/collectors/aws/lookoutvision/describeModel.js
+++ b/collectors/aws/lookoutvision/describeModel.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    LookoutVision
+} = require('@aws-sdk/client-lookoutvision');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var lookoutvision = new AWS.LookoutVision(AWSConfig);
+    var lookoutvision = new LookoutVision(AWSConfig);
 
     if (!collection.lookoutvision ||
         !collection.lookoutvision.listProjects ||
diff --git a/collectors/aws/managedblockchain/getMember.js b/collectors/aws/managedblockchain/getMember.js
index 743f1cad22..4b96294fff 100644
--- a/collectors/aws/managedblockchain/getMember.js
+++ b/collectors/aws/managedblockchain/getMember.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    ManagedBlockchain
+} = require('@aws-sdk/client-managedblockchain');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var managedblockchain = new AWS.ManagedBlockchain(AWSConfig);
+    var managedblockchain = new ManagedBlockchain(AWSConfig);
 
     if (!collection.managedblockchain ||
         !collection.managedblockchain.listNetworks ||
diff --git a/collectors/aws/mwaa/getEnvironment.js b/collectors/aws/mwaa/getEnvironment.js
index 6b9ad3f0eb..79cc4b4bef 100644
--- a/collectors/aws/mwaa/getEnvironment.js
+++ b/collectors/aws/mwaa/getEnvironment.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    MWAA
+} = require('@aws-sdk/client-mwaa');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var mwaa = new AWS.MWAA(AWSConfig);
+    var mwaa = new MWAA(AWSConfig);
 
     async.eachLimit(collection.mwaa.listEnvironments[AWSConfig.region].data, 15, function(env, cb){
         collection.mwaa.getEnvironment[AWSConfig.region][env] = {};
diff --git a/collectors/aws/opensearchserverless/getEncryptionSecurityPolicy.js b/collectors/aws/opensearchserverless/getEncryptionSecurityPolicy.js
index d370a344a0..27e9555ab7 100644
--- a/collectors/aws/opensearchserverless/getEncryptionSecurityPolicy.js
+++ b/collectors/aws/opensearchserverless/getEncryptionSecurityPolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    OpenSearchServerless
+} = require('@aws-sdk/client-opensearchserverless');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.OpenSearchServerless(AWSConfig);
+    var ecs = new OpenSearchServerless(AWSConfig);
 
     async.eachLimit(collection.opensearchserverless.listEncryptionSecurityPolicies[AWSConfig.region].data, 10, function(policy, cb){
         collection.opensearchserverless.getEncryptionSecurityPolicy[AWSConfig.region][policy.name] = {};
diff --git a/collectors/aws/opensearchserverless/getNetworkSecurityPolicy.js b/collectors/aws/opensearchserverless/getNetworkSecurityPolicy.js
index e7ffd7b538..0c5282a19e 100644
--- a/collectors/aws/opensearchserverless/getNetworkSecurityPolicy.js
+++ b/collectors/aws/opensearchserverless/getNetworkSecurityPolicy.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    OpenSearchServerless
+} = require('@aws-sdk/client-opensearchserverless');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ecs = new AWS.OpenSearchServerless(AWSConfig);
+    var ecs = new OpenSearchServerless(AWSConfig);
     async.eachLimit(collection.opensearchserverless.listNetworkSecurityPolicies[AWSConfig.region].data, 10, function(policy, cb){
         collection.opensearchserverless.getNetworkSecurityPolicy[AWSConfig.region][policy.name] = {};
         var params = {
diff --git a/collectors/aws/opensearchserverless/listEncryptionSecurityPolicies.js b/collectors/aws/opensearchserverless/listEncryptionSecurityPolicies.js
index 164092cc06..ab5bf8f4dc 100644
--- a/collectors/aws/opensearchserverless/listEncryptionSecurityPolicies.js
+++ b/collectors/aws/opensearchserverless/listEncryptionSecurityPolicies.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    OpenSearchServerless
+} = require('@aws-sdk/client-opensearchserverless');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var opensearch = new AWS.OpenSearchServerless(AWSConfig);
+    var opensearch = new OpenSearchServerless(AWSConfig);
     collection.opensearchserverless.listEncryptionSecurityPolicies[AWSConfig.region] = {};
     let params = {
         type: 'encryption'
diff --git a/collectors/aws/opensearchserverless/listNetworkSecurityPolicies.js b/collectors/aws/opensearchserverless/listNetworkSecurityPolicies.js
index 99e06b8b01..711a707e08 100644
--- a/collectors/aws/opensearchserverless/listNetworkSecurityPolicies.js
+++ b/collectors/aws/opensearchserverless/listNetworkSecurityPolicies.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    OpenSearchServerless
+} = require('@aws-sdk/client-opensearchserverless');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var opensearch = new AWS.OpenSearchServerless(AWSConfig);
+    var opensearch = new OpenSearchServerless(AWSConfig);
     collection.opensearchserverless.listNetworkSecurityPolicies[AWSConfig.region] = {};
     let params = {
         type: 'network'
diff --git a/collectors/aws/rds/describeDBParameters.js b/collectors/aws/rds/describeDBParameters.js
index 5cf608fa16..c5cc22be7a 100644
--- a/collectors/aws/rds/describeDBParameters.js
+++ b/collectors/aws/rds/describeDBParameters.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    RDS
+} = require('@aws-sdk/client-rds');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var rds = new AWS.RDS(AWSConfig);
+    var rds = new RDS(AWSConfig);
     async.eachLimit(collection.rds.describeDBParameterGroups[AWSConfig.region].data, 15, function(group, cb) {
         collection.rds.describeDBParameters[AWSConfig.region][group.DBParameterGroupName] = {};
         var params = {
diff --git a/collectors/aws/s3/index.js b/collectors/aws/s3/index.js
index bbcac26df5..bfee439a4d 100644
--- a/collectors/aws/s3/index.js
+++ b/collectors/aws/s3/index.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    S3
+} = require('@aws-sdk/client-s3');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(callKey, forceCloudTrail, AWSConfig, collection, retries, callback) {
-    var s3 = new AWS.S3(AWSConfig);
+    var s3 = new S3(AWSConfig);
 
     var knownBuckets = [];
 
@@ -51,7 +53,7 @@ module.exports = function(callKey, forceCloudTrail, AWSConfig, collection, retri
                         
                         var altAWSConfig = JSON.parse(JSON.stringify(AWSConfig));
                         altAWSConfig.region = locData.LocationConstraint;
-                        var s3Alt = new AWS.S3(altAWSConfig);
+                        var s3Alt = new S3(altAWSConfig);
 
                         s3Alt[callKey]({Bucket:bucket}, function(altErr, altData){
                             if (altErr) {
diff --git a/collectors/aws/s3control/getPublicAccessBlock.js b/collectors/aws/s3control/getPublicAccessBlock.js
index 00d57ea3c9..50160d6642 100644
--- a/collectors/aws/s3control/getPublicAccessBlock.js
+++ b/collectors/aws/s3control/getPublicAccessBlock.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    S3Control
+} = require('@aws-sdk/client-s3-control');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var s3control = new AWS.S3Control(AWSConfig);
+    var s3control = new S3Control(AWSConfig);
 
     var accountId = collection.sts.getCallerIdentity[AWSConfig.region].data;
     collection.s3control.getPublicAccessBlock[AWSConfig.region][accountId] = {};
diff --git a/collectors/aws/ses/getIdentityDkimAttributes.js b/collectors/aws/ses/getIdentityDkimAttributes.js
index ee188d4273..ae04e4f1b0 100644
--- a/collectors/aws/ses/getIdentityDkimAttributes.js
+++ b/collectors/aws/ses/getIdentityDkimAttributes.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    SES
+} = require('@aws-sdk/client-ses');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ses = new AWS.SES(AWSConfig);
+    var ses = new SES(AWSConfig);
     collection.ses.getIdentityDkimAttributes[AWSConfig.region] = {};
 
     var identities = collection.ses.listIdentities[AWSConfig.region].data;
diff --git a/collectors/aws/sqs/getQueueAttributes.js b/collectors/aws/sqs/getQueueAttributes.js
index 9da6f17aeb..c9f65b6770 100644
--- a/collectors/aws/sqs/getQueueAttributes.js
+++ b/collectors/aws/sqs/getQueueAttributes.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    SQS
+} = require('@aws-sdk/client-sqs');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var sqs = new AWS.SQS(AWSConfig);
+    var sqs = new SQS(AWSConfig);
 
     async.eachLimit(collection.sqs.listQueues[AWSConfig.region].data, 15, function(queue, cb){
         collection.sqs.getQueueAttributes[AWSConfig.region][queue] = {};
diff --git a/collectors/aws/ssm/describeParameters.js b/collectors/aws/ssm/describeParameters.js
index 4c7eb39321..7250f3c880 100644
--- a/collectors/aws/ssm/describeParameters.js
+++ b/collectors/aws/ssm/describeParameters.js
@@ -1,8 +1,10 @@
-var AWS = require('aws-sdk');
+const {
+    SSM
+} = require('@aws-sdk/client-ssm');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var ssm = new AWS.SSM(AWSConfig);
+    var ssm = new SSM(AWSConfig);
     collection.ssm.describeParameters[AWSConfig.region] = {};
     var params = {};
 
diff --git a/collectors/aws/support/describeTrustedAdvisorCheckResult.js b/collectors/aws/support/describeTrustedAdvisorCheckResult.js
index 4f6cdeda97..73b42f3dec 100644
--- a/collectors/aws/support/describeTrustedAdvisorCheckResult.js
+++ b/collectors/aws/support/describeTrustedAdvisorCheckResult.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    Support
+} = require('@aws-sdk/client-support');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var support = new AWS.Support(AWSConfig);
+    var support = new Support(AWSConfig);
 
     async.eachLimit(collection.support.describeTrustedAdvisorChecks[AWSConfig.region].data, 15, function(check, cb) {
         collection.support.describeTrustedAdvisorChecks[AWSConfig.region][check] = {};
diff --git a/collectors/aws/wafregional/listResourcesForWebACL.js b/collectors/aws/wafregional/listResourcesForWebACL.js
index c1728c507d..7225a0098e 100644
--- a/collectors/aws/wafregional/listResourcesForWebACL.js
+++ b/collectors/aws/wafregional/listResourcesForWebACL.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    WAFRegional
+} = require('@aws-sdk/client-waf-regional');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var wafregional = new AWS.WAFRegional(AWSConfig);
+    var wafregional = new WAFRegional(AWSConfig);
     async.eachLimit(collection.wafregional.listWebACLs[AWSConfig.region].data, 15, function(dep, depCb){
         async.eachLimit(['APPLICATION_LOAD_BALANCER', 'API_GATEWAY'], 1, function(thisCheck, tcCb){
             if (!collection['wafregional']['listResourcesForWebACL'][AWSConfig.region][dep['WebACLId']]) collection['wafregional']['listResourcesForWebACL'][AWSConfig.region][dep['WebACLId']] = {};
diff --git a/collectors/aws/wafv2/getWebACL.js b/collectors/aws/wafv2/getWebACL.js
index b8f5107b13..98c2d77898 100644
--- a/collectors/aws/wafv2/getWebACL.js
+++ b/collectors/aws/wafv2/getWebACL.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    WAFV2
+} = require('@aws-sdk/client-wafv2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var wafv2 = new AWS.WAFV2(AWSConfig);
+    var wafv2 = new WAFV2(AWSConfig);
 
     async.eachLimit(collection.wafv2.listWebACLs[AWSConfig.region].data, 15, function(acl, cb){        
         var params = {
diff --git a/collectors/aws/wafv2/getWebACLForCognitoUserPool.js b/collectors/aws/wafv2/getWebACLForCognitoUserPool.js
index 5e0f685551..16a709aa77 100644
--- a/collectors/aws/wafv2/getWebACLForCognitoUserPool.js
+++ b/collectors/aws/wafv2/getWebACLForCognitoUserPool.js
@@ -1,10 +1,12 @@
-var AWS = require('aws-sdk');
+const {
+    WAFV2
+} = require('@aws-sdk/client-wafv2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
 
-    var wafv2 = new AWS.WAFV2(AWSConfig);
+    var wafv2 = new WAFV2(AWSConfig);
     var region = 'us-east-1';
     var partition = 'aws';
     if (wafv2.endpoint.hostname.includes('gov')){
diff --git a/collectors/aws/wafv2/listResourcesForWebACL.js b/collectors/aws/wafv2/listResourcesForWebACL.js
index 711a45dbef..118a957583 100644
--- a/collectors/aws/wafv2/listResourcesForWebACL.js
+++ b/collectors/aws/wafv2/listResourcesForWebACL.js
@@ -1,9 +1,11 @@
-var AWS = require('aws-sdk');
+const {
+    WAFV2
+} = require('@aws-sdk/client-wafv2');
 var async = require('async');
 var helpers = require(__dirname + '/../../../helpers/aws');
 
 module.exports = function(AWSConfig, collection, retries, callback) {
-    var wafv2 = new AWS.WAFV2(AWSConfig);
+    var wafv2 = new WAFV2(AWSConfig);
     async.eachLimit(collection.wafv2.listWebACLs[AWSConfig.region].data, 15, function(dep, depCb){
         async.eachLimit(['APPLICATION_LOAD_BALANCER', 'API_GATEWAY'], 1,  function(thisCheck, tcCb){
             if (!collection['wafv2']['listResourcesForWebACL'][AWSConfig.region][dep['ARN']]) collection['wafv2']['listResourcesForWebACL'][AWSConfig.region][dep['ARN']] = {};
diff --git a/helpers/aws/functions.js b/helpers/aws/functions.js
index b681ed5743..40ec389534 100644
--- a/helpers/aws/functions.js
+++ b/helpers/aws/functions.js
@@ -1,6 +1,5 @@
 var async = require('async');
 var regions = require(__dirname + '/regions');
-var AWS = require('aws-sdk');
 var helpers = require('../shared.js');
 
 function waitForCredentialReport(iam, callback, CREDENTIAL_DOWNLOAD_STARTED) {
@@ -919,9 +918,9 @@ function getUsedSecurityGroups(cache, results, region) {
         return  result['Error'];
     }
 
-    describeNetworkInterfaces.data.forEach(interface => {
-        if (interface.Groups) {
-            interface.Groups.forEach(group => {
+    describeNetworkInterfaces.data.forEach(networkInterface => {
+        if (networkInterface.Groups) {
+            networkInterface.Groups.forEach(group => {
                 if (!result.includes(group.GroupId)) result.push(group.GroupId);
             });
         }
diff --git a/package.json b/package.json
index 741c0ba80f..9ba645f8f0 100644
--- a/package.json
+++ b/package.json
@@ -40,7 +40,47 @@
   },
   "dependencies": {
     "@alicloud/pop-core": "^1.7.10",
+    "@aws-sdk/client-accessanalyzer": "^3.441.0",
+    "@aws-sdk/client-api-gateway": "^3.441.0",
+    "@aws-sdk/client-app-mesh": "^3.441.0",
+    "@aws-sdk/client-auto-scaling": "^3.441.0",
+    "@aws-sdk/client-cloudfront": "^3.441.0",
+    "@aws-sdk/client-cloudtrail": "^3.441.0",
+    "@aws-sdk/client-cloudwatch": "^3.441.0",
+    "@aws-sdk/client-codebuild": "^3.444.0",
+    "@aws-sdk/client-connect": "^3.444.0",
+    "@aws-sdk/client-dynamodb": "^3.441.0",
+    "@aws-sdk/client-ec2": "^3.441.0",
+    "@aws-sdk/client-ecs": "^3.441.0",
+    "@aws-sdk/client-eks": "^3.441.0",
+    "@aws-sdk/client-elastic-beanstalk": "^3.441.0",
+    "@aws-sdk/client-elastic-load-balancing": "^3.441.0",
+    "@aws-sdk/client-elastic-load-balancing-v2": "^3.441.0",
+    "@aws-sdk/client-elasticache": "^3.441.0",
+    "@aws-sdk/client-emr": "^3.441.0",
+    "@aws-sdk/client-firehose": "^3.441.0",
+    "@aws-sdk/client-guardduty": "^3.441.0",
+    "@aws-sdk/client-iam": "^3.444.0",
+    "@aws-sdk/client-kinesis": "^3.441.0",
+    "@aws-sdk/client-kms": "^3.441.0",
+    "@aws-sdk/client-lex-models-v2": "^3.441.0",
+    "@aws-sdk/client-lookoutvision": "^3.441.0",
+    "@aws-sdk/client-managedblockchain": "^3.441.0",
+    "@aws-sdk/client-mwaa": "^3.444.0",
+    "@aws-sdk/client-opensearchserverless": "^3.441.0",
+    "@aws-sdk/client-rds": "^3.441.0",
+    "@aws-sdk/client-s3": "^3.441.0",
+    "@aws-sdk/client-s3-control": "^3.441.0",
+    "@aws-sdk/client-ses": "^3.441.0",
+    "@aws-sdk/client-sqs": "^3.441.0",
+    "@aws-sdk/client-ssm": "^3.441.0",
+    "@aws-sdk/client-sts": "^3.441.0",
+    "@aws-sdk/client-support": "^3.441.0",
+    "@aws-sdk/client-waf-regional": "^3.441.0",
+    "@aws-sdk/client-wafv2": "^3.441.0",
+    "@aws-sdk/node-http-handler": "^3.374.0",
     "@azure/data-tables": "^13.2.2",
+    "@azure/storage-blob": "^12.14.0",
     "@azure/storage-file-share": "^12.14.0",
     "@azure/storage-queue": "^12.13.0",
     "@azure/storage-blob": "^12.14.0",