update

task/daily_search_word_count_last_two_year.py

@@ -7,6 +7,7 @@
 
 # coding=utf-8
 import hashlib
+import json
 import time
 from pyspark import SparkConf
 from pyspark.sql import SparkSession, DataFrame
@@ -70,7 +71,7 @@ def from_es_get_service_num(query):
         doc_type='service',
         timeout='10s',
         size=0,
-        body=q
+        body=json.dumps(q)
     )
     if results['hits']['total'] > 0:
         return results['hits']['total']