搜索词详情页增加抓取数据

Pyspark_job/sqoop_import/ods_st_quantity_being_sold.py

@@ -27,10 +27,10 @@ if __name__ == '__main__':
             created_time,
             updated_time,
             quantity_being_sold_str,
---             result_count,
             REPLACE(REPLACE(REPLACE(result_count, E'\n',' '), E'\r',' '), E'\t',' ') AS result_count,
-  REPLACE(REPLACE(REPLACE(departments, E'\n',' '), E'\r',' '), E'\t',' ') AS departments
---             departments
+            REPLACE(REPLACE(REPLACE(departments, E'\n',' '), E'\r',' '), E'\t',' ') AS departments,
+            REPLACE(REPLACE(REPLACE(filter_refinements, E'\n',' '), E'\r',' '), E'\t',' ') AS filter_refinements,
+            REPLACE(REPLACE(REPLACE(brand_badge, E'\n',' '), E'\r',' '), E'\t',' ') AS brand_badge
         from {import_table} 
         where 1=1 
         and \$CONDITIONS