FB Marketplace crawler
This commit is contained in:
parent
aaf84022e6
commit
e4b1f8c269
|
@ -25,7 +25,7 @@ class FbMarketplaceProductInfo:
|
||||||
op.add_argument('--user-data-dir=/home/ec2-user/fb-crawler-binary/chrome/fb_marketplace')
|
op.add_argument('--user-data-dir=/home/ec2-user/fb-crawler-binary/chrome/fb_marketplace')
|
||||||
self.version_main = 120
|
self.version_main = 120
|
||||||
self.driver = Chrome(options=op, version_main=self.version_main)
|
self.driver = Chrome(options=op, version_main=self.version_main)
|
||||||
time.sleep(3000)
|
#time.sleep(3000)
|
||||||
|
|
||||||
self.cur.execute("select id from " + self.config.get('crawler_schema') + "." + self.config.get(
|
self.cur.execute("select id from " + self.config.get('crawler_schema') + "." + self.config.get(
|
||||||
'source_tab') + " where source_name='fb_marketplace'")
|
'source_tab') + " where source_name='fb_marketplace'")
|
||||||
|
@ -40,7 +40,7 @@ class FbMarketplaceProductInfo:
|
||||||
|
|
||||||
def run_product_pipeline(self):
|
def run_product_pipeline(self):
|
||||||
|
|
||||||
table = f"""{self.config.get('crawler_schema')}.{self.config.get('tracker_tab')}"""
|
table = f"""{self.config.get('crawler_schema')}.{self.config.get('tracker_tab')} limit 1"""
|
||||||
|
|
||||||
sql = f"""
|
sql = f"""
|
||||||
SELECT * FROM {table} where flag=0 limit 1
|
SELECT * FROM {table} where flag=0 limit 1
|
||||||
|
|
Loading…
Reference in New Issue