|
|
@@ -47,7 +47,7 @@ def write_to_file(jsobj,fname):
|
|
|
def build_cache(db):
|
|
|
global reviews_table
|
|
|
id_dict={}
|
|
|
- cursor = db.query('SELECT fid, author_id FROM google_poi.{};'.format(reviews_table))
|
|
|
+ cursor = db.query('SELECT fid, author_id FROM google_poi.reviews_table;')
|
|
|
|
|
|
for c in cursor:
|
|
|
key = '{}_{}'.format(c['fid'],c['author_id'])
|
|
|
@@ -203,10 +203,11 @@ def main():
|
|
|
localip=socket.gethostbyname(socket.gethostname())
|
|
|
|
|
|
db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/google_poi?charset=utf8mb4')
|
|
|
- iddict=build_cache(db)
|
|
|
store_list_table = db['swire_store_list']
|
|
|
reviews_table = db['reviews_table']
|
|
|
|
|
|
+ iddict=build_cache(db)
|
|
|
+
|
|
|
port=4444
|
|
|
if len(sys.argv) == 3 :
|
|
|
port=int(sys.argv[1])
|
