oss delete

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/VideoCleanExecutor.java

@@ -24,16 +24,15 @@ public class VideoCleanExecutor {
         JavaRDD<String> multiFileRDD = jsc.textFile("/dyp/oss/video_clean/part-00000");
 
         log.info("count {}", multiFileRDD.count());
-
+        OSSService ossService = new OSSService();
         multiFileRDD.repartition(100).foreachPartition(s -> {
             List<String> objectNames = new ArrayList<>();
             if (s.hasNext()) {
                 String[] data = StringUtils.split(s.next(), "\t");
                 objectNames.add(data[2]);
                 log.info("data[2] {}", data[2]);
-                //objectNames.add(data[3]);
             }
-            new OSSService().transToDeepColdArchive("art-pubbucket", objectNames);
+            ossService.transToDeepColdArchive("art-pubbucket", objectNames);
         });
     }
 

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/OSSService.java

@@ -23,6 +23,7 @@ public class OSSService implements Serializable {
         OSS ossClient = new OSSClientBuilder().build(endpoint, accessId, accessKey);
         for (String objectName : objectNames) {
             try {
+                objectName = "longvideo/transcode/video/vpc/20220919/19927351LCBOxjafmK4ppBpTCx.mp4";
                 CopyObjectRequest request = new CopyObjectRequest(bucketName, objectName, bucketName, objectName);
                 ObjectMetadata objectMetadata = new ObjectMetadata();
                 objectMetadata.setHeader("x-oss-storage-class", "DeepColdArchive");