| | |
| | | import com.ard.sample.config.DockConfiguration; |
| | | import com.ard.sample.storage.service.IStorageService; |
| | | import com.ard.oss.service.impl.OssServiceContext; |
| | | import com.ard.sample.utils.MinioStsUtils; |
| | | import io.minio.MinioClient; |
| | | import io.minio.PutObjectArgs; |
| | | import io.minio.credentials.StaticProvider; |
| | |
| | | |
| | | @Autowired |
| | | private OssServiceContext ossService; |
| | | @Autowired |
| | | private MinioStsUtils minioStsUtils; |
| | | |
| | | @Override |
| | | public StsCredentialsDTO getSTSCredentials() { |
| | | CredentialsDTO credentials = ossService.getCredentials(); |
| | | // CredentialsDTO credentials = minioStsUtils.getCredentials(); |
| | | |
| | | //验证一下minio的临时凭证是否可用 |
| | | log.info("验证http临时凭证是否有效:{}", credentials); |
| | | execMinio(DockConfiguration.endpoint, |
| | | credentials.getAccessKeyId(), |
| | | credentials.getAccessKeySecret(), |
| | | credentials.getSecurityToken(), |
| | | OssConfiguration.region, |
| | | DockConfiguration.bucket, |
| | | "test_object_http"); |
| | | |
| | | log.info("验证https临时凭证是否有效:{}", credentials); |
| | | execMinio(OssConfiguration.endpoint, |
| | |
| | | |
| | | return StsCredentialsDTO.builder() |
| | | //机场媒体库minio配置信息用代理地址,桶用机场的桶。 |
| | | .endpoint(OssConfiguration.endpoint) |
| | | .endpoint(DockConfiguration.endpoint) |
| | | .bucket(DockConfiguration.bucket) |
| | | .credentials(credentials) |
| | | .provider(DockConfiguration.provider) |