增加top1缓存

ad-engine-service/pom.xml

@@ -25,6 +25,10 @@
             <artifactId>ad-engine-commons</artifactId>
             <version>1.1.0</version>
         </dependency>
-
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-sdk-core</artifactId>
+            <version>0.45.6-public</version>
+        </dependency>
     </dependencies>
 </project>

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/predict/container/TopOneVideoContainer.java

@@ -0,0 +1,4 @@
+package com.tzld.piaoquan.ad.engine.service.predict.container;
+
+public class TopOneVideoContainer {
+}

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/predict/odps/ODPSClient.java

@@ -0,0 +1,52 @@
+package com.tzld.piaoquan.ad.engine.service.predict.odps;
+
+import com.aliyun.odps.*;
+import com.aliyun.odps.account.Account;
+import com.aliyun.odps.account.AliyunAccount;
+import com.aliyun.odps.data.Record;
+import com.aliyun.odps.task.SQLTask;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import java.util.*;
+@Service
+public class ODPSClient {
+
+    @Value("${ad.odps.access.id:LTAIWYUujJAm7CbH}")
+    public String odpsAccessId;
+    @Value("${ad.odps.access.key:RfSjdiWwED1sGFlsjXv0DlfTnZTG1P}")
+    public String odpsAAccessKey;
+    @Value("${ad.odps.endpoint:http://service.cn.maxcompute.aliyun.com/api}")
+    public String odpsEndpoint;
+
+    private Odps odps;
+
+    public void initClient(){
+        Account account = new AliyunAccount(odpsAccessId, odpsAAccessKey);
+        odps = new Odps(account);
+        odps.setEndpoint(odpsEndpoint);
+        odps.setDefaultProject("loghubods");
+    }
+
+
+    public static void main(String[] args) throws Exception{
+        Account account = new AliyunAccount("LTAIWYUujJAm7CbH", "RfSjdiWwED1sGFlsjXv0DlfTnZTG1P");
+        Odps odps = new Odps(account);
+        odps.setEndpoint("http://service.cn.maxcompute.aliyun.com/api");
+        odps.setDefaultProject("loghubods");
+        Instance i;
+        String sql="select * from top_return_videolist_hh where dt=2024011710;";
+        try {
+            i = SQLTask.run(odps, sql);
+            i.waitForSuccess();
+            List<Record> records = SQLTask.getResult(i);
+            for(Record r:records){
+                System.out.println(r.get("apptype").toString());
+                System.out.println(r.get("videoid").toString());
+                System.out.println(r.get("rank").toString());
+                System.out.println("-0-----------------");
+            }
+        } catch (OdpsException e) {
+            e.printStackTrace();
+        }
+    }
+}

pom.xml

@@ -219,6 +219,10 @@
             <artifactId>commons-external</artifactId>
             <version>1.0-SNAPSHOT</version>
             <exclusions>
+                <exclusion>
+                    <groupId>org.codehaus.woodstox</groupId>
+                    <artifactId>stax2-api</artifactId>
+                </exclusion>
                 <exclusion>
                     <groupId>com.aliyun.oss</groupId>
                     <artifactId>aliyun-sdk-oss</artifactId>
@@ -234,6 +238,7 @@
                 </exclusion>
             </exclusions>
         </dependency>
+
         <dependency>
             <groupId>com.aliyun</groupId>
             <artifactId>aliyun-java-sdk-core</artifactId>