| 155 | } |
| 156 | |
| 157 | minifi::utils::optional<Aws::Auth::AWSCredentials> S3Processor::getAWSCredentials( |
| 158 | const std::shared_ptr<core::ProcessContext> &context, |
| 159 | const std::shared_ptr<core::FlowFile> &flow_file) { |
| 160 | auto service_cred = getAWSCredentialsFromControllerService(context); |
| 161 | if (service_cred) { |
| 162 | logger_->log_info("AWS Credentials successfully set from controller service"); |
| 163 | return service_cred.value(); |
| 164 | } |
| 165 | |
| 166 | std::string access_key; |
| 167 | context->getProperty(AccessKey, access_key, flow_file); |
| 168 | aws::AWSCredentialsProvider aws_credentials_provider; |
| 169 | aws_credentials_provider.setAccessKey(access_key); |
| 170 | std::string secret_key; |
| 171 | context->getProperty(SecretKey, secret_key, flow_file); |
| 172 | aws_credentials_provider.setSecretKey(secret_key); |
| 173 | std::string credential_file; |
| 174 | context->getProperty(CredentialsFile.getName(), credential_file); |
| 175 | aws_credentials_provider.setCredentialsFile(credential_file); |
| 176 | bool use_default_credentials = false; |
| 177 | context->getProperty(UseDefaultCredentials.getName(), use_default_credentials); |
| 178 | aws_credentials_provider.setUseDefaultCredentials(use_default_credentials); |
| 179 | |
| 180 | return aws_credentials_provider.getAWSCredentials(); |
| 181 | } |
| 182 | |
| 183 | minifi::utils::optional<aws::s3::ProxyOptions> S3Processor::getProxy(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::FlowFile> &flow_file) { |
| 184 | aws::s3::ProxyOptions proxy; |
no test coverage detected