更新 预处理 索引结构

pre_extract/es.go

@@ -26,6 +26,9 @@ var mapping = `    "mappings": {
             },
              "object_type": {
                 "type": "keyword"
+            },
+			"fromtable": {
+                "type": "keyword"
             },
             "bidopentime": {
                 "type": "long"

pre_extract/pre_test.go

@@ -60,7 +60,7 @@ func TestCreateIndex(t *testing.T) {
 		clients[k] = client
 	}
 
-	err := CreateIndex(clients, "bidding_2023112214")
+	err := CreateIndex(clients, "bidding_2023112216")
 	fmt.Println(err)
 
 }