diff --git a/internal/impl/sql/cache_sql.go b/internal/impl/sql/cache_sql.go index d46a9e4c3..5478c03c5 100644 --- a/internal/impl/sql/cache_sql.go +++ b/internal/impl/sql/cache_sql.go @@ -166,9 +166,11 @@ func newSQLCacheFromConfig(conf *service.ParsedConfig, mgr *service.Resources) ( return nil, err } - s.awsConf, err = bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + if s.driver == "postgres" && connSettings.secretName != "" { + s.awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } if s.db, err = sqlOpenWithReworks(context.Background(), s.logger, s.driver, s.dsn, connSettings, s.awsConf); err != nil { diff --git a/internal/impl/sql/input_sql_raw.go b/internal/impl/sql/input_sql_raw.go index d809bb48d..51895f093 100644 --- a/internal/impl/sql/input_sql_raw.go +++ b/internal/impl/sql/input_sql_raw.go @@ -124,9 +124,11 @@ func newSQLRawInputFromConfig(conf *service.ParsedConfig, mgr *service.Resources if s.connSettings, err = connSettingsFromParsed(conf, mgr); err != nil { return nil, err } - s.awsConf, err = bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + if s.driver == "postgres" && s.connSettings.secretName != "" { + s.awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } return s, nil diff --git a/internal/impl/sql/input_sql_select.go b/internal/impl/sql/input_sql_select.go index f777372ef..817fa16d0 100644 --- a/internal/impl/sql/input_sql_select.go +++ b/internal/impl/sql/input_sql_select.go @@ -177,9 +177,11 @@ func newSQLSelectInputFromConfig(conf *service.ParsedConfig, mgr *service.Resour return nil, err } - s.awsConf, err = bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + if s.driver == "postgres" && s.connSettings.secretName != "" { + s.awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } return s, nil } diff --git a/internal/impl/sql/output_sql_insert.go b/internal/impl/sql/output_sql_insert.go index f6f3944ad..71a5020ea 100644 --- a/internal/impl/sql/output_sql_insert.go +++ b/internal/impl/sql/output_sql_insert.go @@ -184,9 +184,11 @@ func newSQLInsertOutputFromConfig(conf *service.ParsedConfig, mgr *service.Resou return nil, err } - s.awsConf, err = bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + if s.driver == "postgres" && s.connSettings.secretName != "" { + s.awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } return s, nil diff --git a/internal/impl/sql/processor_sql_insert.go b/internal/impl/sql/processor_sql_insert.go index a9dabba50..553bb06af 100644 --- a/internal/impl/sql/processor_sql_insert.go +++ b/internal/impl/sql/processor_sql_insert.go @@ -7,6 +7,7 @@ import ( "sync" "github.com/Masterminds/squirrel" + "github.com/aws/aws-sdk-go-v2/aws" "github.com/Jeffail/shutdown" @@ -173,9 +174,12 @@ func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Re return nil, err } - awsConf, err := bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + var awsConf aws.Config + if driverStr == "postgres" && connSettings.secretName != "" { + awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } if s.db, err = sqlOpenWithReworks(context.Background(), mgr.Logger(), driverStr, dsnStr, connSettings, awsConf); err != nil { diff --git a/internal/impl/sql/processor_sql_select.go b/internal/impl/sql/processor_sql_select.go index 4e5dd54c0..30525e763 100644 --- a/internal/impl/sql/processor_sql_select.go +++ b/internal/impl/sql/processor_sql_select.go @@ -175,9 +175,11 @@ func NewSQLSelectProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Re return nil, err } - s.awsConf, err = bento_aws.GetSession(context.Background(), conf) - if err != nil { - return nil, err + if driverStr == "postgres" && connSettings.secretName != "" { + s.awsConf, err = bento_aws.GetSession(context.Background(), conf) + if err != nil { + return nil, err + } } if s.db, err = sqlOpenWithReworks(context.Background(), mgr.Logger(), driverStr, dsnStr, connSettings, s.awsConf); err != nil {