Changes

invoke.py

@@ -1,18 +1,19 @@
 import requests
 
 cmd_str = """
-def factorial(num):
-    fact=1
-    for i in range(1,num+1):
-        fact = fact*i
-    return fact
+def exec(obj):
+    obj['name2']=2
+    obj['name3']=2
+    return obj
 """
 
-print(requests.post("http://172.18.205.202:8000/exec", json={
+print(requests.post("http://172.18.162.173:8000/exec", json={
     "function_str": cmd_str,
-    "call_str": "factorial(num)",
+    "call_str": "exec(obj)",
     "param_dict": {
-        "num": 3
+        "obj": {
+            "name": 1
+        }
     }
 }).json())
 
@@ -21,4 +22,4 @@ print(requests.post("http://172.18.205.202:8000/exec", json={
 # 第三个参数：入参，以dict形式传递
 
 # 返回值
-{'code': 200, 'res': 6}
+# {'code': 200, 'res': 6}

project-test/bigtree-aircp/debug.py → project-test/bigtree-aircp/flink.py

@@ -31,19 +31,12 @@ class MyTest(unittest.TestCase):
 
     # 原子标签
     def testComputer(self):
-        reqForm("http://localhost:8080/test/dealWithTagCompute", {
-            "computeType": 3,
-            "dataSourceCode": "mysqlTestHu123",
-            "dataSourceType": "mysql",
-            "dimensionNo": "10449",
-            "dimensionsName": "amount",
-            "entityName": "实体测试HU421445",
-            "entityNo": "EN882632280592436445",
-            "primaryKey": "projectcode",
-            "primaryTableName": "shopping",
-            "tagName": "采购类型222",
-            "tagNo": "TAG16693657062277747"
-        })
+        reqForm("http://localhost:8080/test/dealWithTagCompute",
+                {"computeType": 3, "dataSourceCode": "tn_markting_db", "dataSourceType": "oracle",
+                 "dimensionNo": "10610", "dimensionsName": "GENDER", "entityName": "tn营销基本信息",
+                 "entityNo": "EN892456279547714785", "primaryKey": "CST_ID", "primaryTableName": "DC_CST_INFO",
+                 "tagName": "性别0-未知的性别1-男性2-女性9-未说明的性别", "tagNo": "TAG16693487690724795",
+                 "tenantId": "TENA883826260025957899"})
 
     # 衍生标签
     def testComputer2(self):
@@ -52,7 +45,8 @@ class MyTest(unittest.TestCase):
                  "entityName": "mysqlTestShopping33333(mysql数据源)", "entityNo": "EN875254841037837824",
                  "packageId": "rxdp/mySqlShoppingTest112", "primaryKey": "projectcode", "primaryTableName": "shopping",
                  "statisticsCycle": "year", "statisticsCycleTime": "createtime",
-                 "tagName": "衍生标签测试多数据源mysql33333", "tagNo": "TAG16674623867383022", "timeStyle": "TS2"})
+                 "tagName": "衍生标签测试多数据源mysql33333", "tagNo": "TAG16674623867383022", "timeStyle": "TS2",
+                 "tenantId": "test-test-test2"})
 
     # sql标签
     def testComputer3(self):
@@ -61,4 +55,4 @@ class MyTest(unittest.TestCase):
                  "entityName": "mysql实体HU123", "entityNo": "EN879274694203750264", "primaryKey": "business_code",
                  "primaryTableName": "shopping",
                  "tagCompuleSql": "SELECT projectcode AS businessCode,amount AS tagValue FROM shopping LIMIT ${startNum},${endNum}",
-                 "tagName": "SQL标签HU1112", "tagNo": "TAG16684123244372739"})
+                 "tagName": "SQL标签HU1112", "tagNo": "TAG16684123244372739", "tenantId": "test-test-test3"})

sh/tmp.sh

@@ -7,3 +7,10 @@ rxdpdev rxdptest rxdpsl: "
     echo "rxdpdev"
   fi
 }
+
+
+funmv(){
+   newfile=`echo $1 | sed "s/$2/$3/g"`
+   mv $1 $newfile
+}
+funmv

tmp/kafka/kafkaReceiveTest.py

@@ -1,11 +1,9 @@
-from kafka import KafkaConsumer, TopicPartition
-
-
-
-consumer = KafkaConsumer('eip_rec_behave',
+from kafka import KafkaConsumer
+# tag_sink_topic\tag_atom_topic
+consumer = KafkaConsumer('tag_atom_topic',
                          group_id='test11',  # 一个组消费一次
                          auto_offset_reset='latest',  # 从最新数据读取,earliest,latest
-                         bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
+                         bootstrap_servers=['kafka-0.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092','kafka-1.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092','kafka-2.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092']
                          )
 for msg in consumer:
     print(msg.value)