feat: add 商品销量追踪

XuCcc · Mar 20, 2019 · 60141bf · 60141bf
1 parent bdfa2b7
commit 60141bf
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/DuTracker/items.py b/DuTracker/items.py
@@ -40,3 +40,4 @@ class PriceItem(scrapy.Item):
     size = scrapy.Field()
     formatSize = scrapy.Field()
     price = scrapy.Field()
+    soldNum=scrapy.Field()
diff --git a/DuTracker/pipelines.py b/DuTracker/pipelines.py
@@ -99,7 +99,8 @@ def process_item(self, item, spider):
         size = item.get('size')
         formatSize = item.get('formatSize')
         price = item.get('price')
-        points = gen_points(brandId, btitle, pid, title, size, formatSize, price)
+        soldNum = item.get('soldNum')
+        points = gen_points(brandId, btitle, pid, title, size, formatSize, price, soldNum)
         try:
             result = influxdb.write_points(points)
         except  Exception as e:

diff --git a/DuTracker/tsdb.py b/DuTracker/tsdb.py
@@ -18,7 +18,7 @@
 influxdb = InfluxDBClient(_host, _port, _username, _password, _database)
 
 
-def gen_points(brandId, btitle, productId, title, size, formatSize, price):
+def gen_points(brandId, btitle, productId, title, size, formatSize, price, soldNum):
     return [{
         'measurement': f"branId_{brandId}",
         'tags': {
@@ -29,6 +29,7 @@ def gen_points(brandId, btitle, productId, title, size, formatSize, price):
             'formatSize': formatSize,
         },
         'fields': {
-            'price': price
+            'price': price,
+            'soldNum': soldNum
         }
     }]