Spaces:
Runtime error
Runtime error
Commit
·
317bb33
1
Parent(s):
2fac4a6
Update app.py
Browse files
app.py
CHANGED
|
@@ -33,15 +33,15 @@ from datasets import load_dataset
|
|
| 33 |
|
| 34 |
DB_FILE = "./reviewsitr.db"
|
| 35 |
|
| 36 |
-
TOKEN = os.environ.get('HF_KEY')
|
| 37 |
|
| 38 |
-
repo = huggingface_hub.Repository(
|
| 39 |
-
local_dir="data",
|
| 40 |
-
repo_type="dataset",
|
| 41 |
-
clone_from="CognitiveScience/csdhdata",
|
| 42 |
-
use_auth_token=TOKEN
|
| 43 |
-
)
|
| 44 |
-
repo.git_pull()
|
| 45 |
|
| 46 |
#TOKEN2 = HF_TOKEN
|
| 47 |
|
|
@@ -63,14 +63,14 @@ except sqlite3.OperationalError:
|
|
| 63 |
db.execute(
|
| 64 |
'''
|
| 65 |
CREATE TABLE reviews (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
|
| 66 |
-
created_at TIMESTAMP DEFAULT
|
| 67 |
name TEXT, view TEXT, duration TEXT)
|
| 68 |
''')
|
| 69 |
db.commit()
|
| 70 |
db.close()
|
| 71 |
|
| 72 |
db = sqlite3.connect(DB_FILE)
|
| 73 |
-
|
| 74 |
def get_latest_reviews(db: sqlite3.Connection):
|
| 75 |
reviews = db.execute("SELECT * FROM reviews ORDER BY id DESC limit 100").fetchall()
|
| 76 |
total_reviews = db.execute("Select COUNT(id) from reviews").fetchone()[0]
|
|
@@ -99,7 +99,7 @@ def ccogsphere(name: str, rate: int, celsci: str):
|
|
| 99 |
duration = str(row["duration"])
|
| 100 |
print(view, duration)
|
| 101 |
#celsci=celsci+celsci2
|
| 102 |
-
cursor.execute("INSERT INTO reviews(name, view, duration) VALUES(?,?,?)", [celsci+str(index+1), view, duration])
|
| 103 |
db.commit()
|
| 104 |
|
| 105 |
reviews, total_reviews = get_latest_reviews(db)
|
|
@@ -223,12 +223,12 @@ scheduler1 = BackgroundScheduler()
|
|
| 223 |
scheduler1.add_job(func=load_data, trigger="interval", seconds=5)
|
| 224 |
scheduler1.start()
|
| 225 |
|
| 226 |
-
scheduler2 = BackgroundScheduler()
|
| 227 |
-
scheduler2.add_job(func=backup_db, trigger="interval", seconds=3633)
|
| 228 |
-
scheduler2.start()
|
| 229 |
|
| 230 |
-
scheduler3 = BackgroundScheduler()
|
| 231 |
-
scheduler3.add_job(func=backup_db_csv, trigger="interval", seconds=3666)
|
| 232 |
-
scheduler3.start()
|
| 233 |
|
| 234 |
demo.launch()
|
|
|
|
| 33 |
|
| 34 |
DB_FILE = "./reviewsitr.db"
|
| 35 |
|
| 36 |
+
#TOKEN = os.environ.get('HF_KEY')
|
| 37 |
|
| 38 |
+
#repo = huggingface_hub.Repository(
|
| 39 |
+
# local_dir="data",
|
| 40 |
+
# repo_type="dataset",
|
| 41 |
+
# clone_from="CognitiveScience/csdhdata",
|
| 42 |
+
# use_auth_token=TOKEN
|
| 43 |
+
#)
|
| 44 |
+
#repo.git_pull()
|
| 45 |
|
| 46 |
#TOKEN2 = HF_TOKEN
|
| 47 |
|
|
|
|
| 63 |
db.execute(
|
| 64 |
'''
|
| 65 |
CREATE TABLE reviews (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
|
| 66 |
+
created_at TIMESTAMP DEFAULT (datetime('now', 'localtime', '+3 hours')) NOT NULL,
|
| 67 |
name TEXT, view TEXT, duration TEXT)
|
| 68 |
''')
|
| 69 |
db.commit()
|
| 70 |
db.close()
|
| 71 |
|
| 72 |
db = sqlite3.connect(DB_FILE)
|
| 73 |
+
# #created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
|
| 74 |
def get_latest_reviews(db: sqlite3.Connection):
|
| 75 |
reviews = db.execute("SELECT * FROM reviews ORDER BY id DESC limit 100").fetchall()
|
| 76 |
total_reviews = db.execute("Select COUNT(id) from reviews").fetchone()[0]
|
|
|
|
| 99 |
duration = str(row["duration"])
|
| 100 |
print(view, duration)
|
| 101 |
#celsci=celsci+celsci2
|
| 102 |
+
cursor.execute("INSERT INTO reviews(name, view, duration) VALUES(?,?,?)", [celsci+" Video #"+str(index+1), view, duration])
|
| 103 |
db.commit()
|
| 104 |
|
| 105 |
reviews, total_reviews = get_latest_reviews(db)
|
|
|
|
| 223 |
scheduler1.add_job(func=load_data, trigger="interval", seconds=5)
|
| 224 |
scheduler1.start()
|
| 225 |
|
| 226 |
+
#scheduler2 = BackgroundScheduler()
|
| 227 |
+
#scheduler2.add_job(func=backup_db, trigger="interval", seconds=3633)
|
| 228 |
+
#scheduler2.start()
|
| 229 |
|
| 230 |
+
#scheduler3 = BackgroundScheduler()
|
| 231 |
+
#scheduler3.add_job(func=backup_db_csv, trigger="interval", seconds=3666)
|
| 232 |
+
#scheduler3.start()
|
| 233 |
|
| 234 |
demo.launch()
|