فهرست منبع

Revert "수정"

This reverts commit 4b0fdc85dee8dd653e769a05d63b2782ac6e6546.
ect (or 2du) 8 سال پیش
والد
کامیت
5bb2029ee5
5فایلهای تغییر یافته به همراه12 افزوده شده و 9 حذف شده
  1. 1 3
      app.py
  2. 6 4
      back_reset.py
  3. 1 1
      delete_recaptcha.py
  4. 1 0
      func.py
  5. 3 1
      mark.py

+ 1 - 3
app.py

@@ -7,8 +7,6 @@ from tornado.wsgi import WSGIContainer
 from tornado.httpserver import HTTPServer
 from tornado.ioloop import IOLoop
 
-from sqlite3worker import Sqlite3Worker
-
 import platform
 import bcrypt
 import difflib
@@ -49,7 +47,7 @@ except:
             pass
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db')
+conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
 curs = conn.cursor()
 
 # 기타 설정 변경

+ 6 - 4
back_reset.py

@@ -12,12 +12,12 @@ json_data = open('set.json').read()
 set_data = json.loads(json_data)
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db')
+conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
 curs = conn.cursor()
 
 # 파싱 해주는 함수
 def parser(data):
-    namumark(conn, data[0], data[1], 1)
+    namumark(conn, data[0], data[1], 1, 0, 0)
 
 # 역링크 전부 삭제
 curs.execute("delete from back")
@@ -32,8 +32,10 @@ for test in data:
     # 제목 프린트
     print(test[0])
 
-    # 파싱
-    parser(test)
+    # 스레드 기반으로 처리
+    t = threading.Thread(target = parser, args = [test])
+    t.start()
+    t.join()
 
 # 커밋
 conn.commit()

+ 1 - 1
delete_recaptcha.py

@@ -6,7 +6,7 @@ json_data = open('set.json').read()
 set_data = json.loads(json_data)
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db')
+conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
 curs = conn.cursor()
 
 # 데이터 삭제

+ 1 - 0
func.py

@@ -4,6 +4,7 @@ from flask import session, render_template
 from urllib import parse
 
 import json
+import sqlite3
 import hashlib
 import requests
 import re

+ 3 - 1
mark.py

@@ -27,7 +27,9 @@ def namumark(conn, title, data, num):
     data = start(conn, data, title)
     if num == 1:        
         for back_data in data[2]:
-            plusing(conn, back_data[0], back_data[1], back_data[2])
+            thread_start = threading.Thread(target = plusing, args = [conn, back_data[0], back_data[1], back_data[2]])
+            thread_start.start()
+            thread_start.join()
 
         conn.commit()