seo_rds_sendjob.py 5.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. import redis
  2. import time
  3. import dataset
  4. import random
  5. import codecs
  6. #qlist=['富億空間設計','富億空間設計 新成屋','富億空間設計 新成屋','富億空間設計 老屋翻新','富億空間設計 陳錦樹','富億空間設計 設計師','富億空間設計 室內設計','富億空間設計 室內設計師']
  7. #qlist+=['上築空間設計','豐聚室內裝修','富億空間設計','浩室設計','京璽國際','IS國際設計','優尼客','摩登雅舍','亞維空間設計','比沙列','富億設計','豐聚設計']
  8. #qlist=['豐聚設計','豐聚設計 黃翊峰','豐聚設計 李羽芝','豐聚設計 休閒風','豐聚設計 現代風','豐聚設計 工業風','豐聚設計 設計大獎']
  9. #qlist+=['京璽國際','京璽國際 周彥如','京璽國際 設計師','京璽國際 現代風','京璽國際 美式風','京璽國際 奢華風','京璽國際 新成屋']
  10. #qlist+=['合砌設計','合砌設計 臺北市','合砌設計 南港區','合砌設計 忠孝東路','合砌設計 簡約','合砌設計 現代風','合砌設計 徐俊福']
  11. #qlist+=['朱英凱室內設計','朱英凱室內設計 室內設計','朱英凱室內設計 國際大賞','朱英凱室內設計 GLORY','朱英凱室內設計 動線','朱英凱室內設計 設計費','朱英凱室內設計 毛坯屋']
  12. #qlist+=['演拓設計','演拓設計 殷崇淵','演拓設計 張德良','演拓設計 楊霈瀅','演拓設計 寬寬','演拓設計 廖文祥','演拓設計 設計裝潢']
  13. #qlist+=['玖柞設計','玖柞設計 朱伯晟','玖柞設計 蔡雅怡','玖柞設計 新宅','玖柞設計 室內設計','玖柞設計 建築','玖柞設計 裝潢設計']
  14. #qlist+=['卓林室內設計','卓林室內設計 林繹寬','卓林室內設計 設計師','卓林室內設計 機能宅','卓林室內設計 室內設計','卓林室內設計 室內設計','卓林室內設計 坪效','卓林室內設計 空間設計']
  15. #qlist+=['合砌設計','羽筑空間設計','朱英凱室內設計','將作空間','藝谷空間','文儀室內裝修','維耕設計','亞維空間設計','比沙列','上築空間設計','京璽國際','IS國際設計','優尼客','摩登雅舍','玖柞設計','麻石設計','元典設計','大琚空間','惹雅國際','橙果創意','PLSB建境','聯寬室內裝修']
  16. #qlist+=['奧立佛竺居 設計師 鍾鼎','奧立佛竺居 老屋翻新','奧立佛竺居 住宅改造','奧立佛竺居 監工費','奧立佛竺居 設計 鍾黎','奧立佛竺居 謝雨竹']
  17. #qlist+=['IS國際設計','IS國際設計','IS國際設計 陳嘉鴻','IS國際設計 費用','IS國際設計 陳嘉鴻 mobile01','IS國際設計 風格','IS國際設計 接案風格','IS國際設計 現代風','IS國際設計 老屋翻新']
  18. #qlist+=['富億設計','富億設計 新成屋','富億設計 新成屋','富億設計 老屋翻新','富億設計 陳錦樹','富億設計 設計師','富億設計 室內設計','富億設計 室內設計師']
  19. #qlist=['界陽大司','界陽大司 空間設計','界陽大司 設計','界陽大司 馬健凱','界陽大司 室內設計師','界陽大司 案例','界陽大司 室內設計獎']
  20. def get_list():
  21. result=[]
  22. fr=codecs.open('C:/data/Queries.csv','r','utf-8')
  23. lines=fr.readlines()
  24. fr.close()
  25. for l in lines[1:]:
  26. elmts=l.split(',')
  27. pos=float(elmts[4])
  28. if pos<=11:
  29. result.append(elmts[0])
  30. return result
  31. qlist=[]
  32. def get_list_from_db():
  33. global qlist
  34. db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/hhh?charset=utf8mb4')
  35. cursor=db.query("SELECT kw FROM hhh.seo_designer where vipgroup='V';")
  36. for c in cursor:
  37. qlist.append(c['kw'])
  38. def get_list_from_db2():
  39. global qlist
  40. db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/hhh?charset=utf8mb4')
  41. query="""SELECT query as kw FROM hhh.gsc_designer where
  42. (`page` = 'https://hhh.com.tw/designers/cases/491/1-page/new-sort/') or
  43. (`page` = 'https://hhh.com.tw/designers/cases/31/1-page/new-sort/') or
  44. (`page` = 'https://hhh.com.tw/designers/cases/293/1-page/new-sort/') or
  45. (`page` = 'https://hhh.com.tw/designers/cases/278/1-page/new-sort/') or
  46. (`page` = 'https://hhh.com.tw/designers/cases/24/1-page/new-sort/') or
  47. (`page` = 'https://hhh.com.tw/designers/cases/594/1-page/new-sort/') or
  48. (`page` = 'https://hhh.com.tw/designers/cases/356/1-page/new-sort/') or
  49. (`page` = 'https://hhh.com.tw/designers/cases/307/1-page/new-sort/') or
  50. (`page` = 'https://hhh.com.tw/designers/cases/491/1-page/new-sort/') or
  51. (`page` = 'https://hhh.com.tw/designers/cases/33/1-page/new-sort/') or
  52. (`page` = 'https://hhh.com.tw/designers/cases/385/1-page/new-sort/') and position <=10
  53. order by impressions/position desc;
  54. """
  55. cursor=db.query(query)
  56. for c in cursor:
  57. qlist.append(c['kw'])
  58. qlist=get_list()
  59. #get_list_from_db()
  60. #get_list_from_db2()
  61. def process_one():
  62. global qlist
  63. r = redis.Redis(host='db.ptt.cx', port=6379, db=1)
  64. #p = r.pubsub(ignore_subscribe_messages=True)
  65. for i in range(12):
  66. q=random.choice(qlist)
  67. r.publish('q_hhh_seo',q)
  68. # for q in qlist:
  69. # r.publish('q_hhh_seo',q)
  70. #process_one()
  71. for i in range(3):
  72. process_one()