Los objetos creados en un hilo solo se pueden usar en ese mismo hilo

No puedo encontrar el problema:

@app.route('/register', methods=['GET', 'POST'])
def register():
    form = RegisterForm(request.form)
    if request.method=='POST' and form.validate():
        name =  form.name.data 
        email = form.email.data
        username = form.username.data
        password = sha256_crypt.encrypt(str(form.password.data))

        c.execute("INSERT INTO users(name,email,username,password) 
        VALUES(?,?,?,?)", (name, email, username, password))

        conn.commit

        conn.close()

Error:

Archivo “C:\Users\app.py”, línea 59, en el registro c.execute(“INSERTAR EN usuarios(nombre, correo electrónico, nombre de usuario, contraseña) VALORES (?,?,?,?)”, (nombre, correo electrónico , nombre de usuario, contraseña)) Error de programación: los objetos SQLite creados en un subproceso solo se pueden usar en ese mismo subproceso. El objeto se creó en el subproceso id 23508 y este es el subproceso id 22640

¿Significa esto que no puedo usar el nombre, el nombre de usuario y la contraseña del correo electrónico en un archivo HTML? ¿Cómo puedo solucionar esto?

Cuando realice su conexión a la base de datos, agregue lo siguiente.

conn = sqlite3.connect('your.db', check_same_thread=False)

Su cursor ‘c’ no se crea en el mismo hilo; probablemente se inicializó cuando se ejecutó la aplicación Flask.

Probablemente desee generar objetos SQLite (la conexión y el cursor) en el mismo método, como:

  @app.route("https://stackoverflow.com/")
  def dostuff():
    with sql.connect("database.db") as con:
      name = "bob"
      cur = con.cursor()
      cur.execute("INSERT INTO students (name) VALUES (?)",(name))
      con.commit()
      msg = "Done"

engine = create_engine(
'sqlite:///restaurantmenu.db',
connect_args={'check_same_thread': False}
)

Funciona para mi

Puedes probar esto:

engine=create_engine('sqlite:///data.db', echo=True, connect_args={"check_same_thread": False})

funcionó para mí

En mi caso, tengo el mismo problema con dos archivos python que crean un motor sqlite y, por lo tanto, posiblemente operen en diferentes subprocesos. Leyendo el documento de SQLAlchemy aquíparece que es mejor usar la técnica singleton en ambos archivos:

# maintain the same connection per thread
from sqlalchemy.pool import SingletonThreadPool
engine = create_engine('sqlite:///mydb.db',
                poolclass=SingletonThreadPool)

No resuelve todos los casos, lo que significa que ocasionalmente obtengo el mismo error, pero puedo solucionarlo fácilmente, actualizando la página del navegador. Como solo estoy usando esto para depurar mi código, está bien para mí. Para una solución más permanente, probablemente debería elegir otra base de datos, como PostgreSQL u otra base de datos

Tuve el mismo problema y lo solucioné cerrando mi conexión después de cada llamada:

results = session.query(something, something).all()
session.close()

Como se menciona en https://docs.python.org/3/library/sqlite3.html y señalado por @Snidhi Sofpro en un comentario

De forma predeterminada, check_same_thread es True y solo el hilo de creación puede usar la conexión. Si se establece en False, la conexión devuelta se puede compartir entre varios subprocesos. Cuando se utilizan varios subprocesos con la misma conexión, el usuario debe serializar las operaciones de escritura para evitar la corrupción de datos.

Una forma de lograr la serialización:

import threading
import sqlite3
import queue
import traceback
import time
import random

work_queue = queue.Queue()

def sqlite_worker():
    con = sqlite3.connect(':memory:', check_same_thread=False)
    cur = con.cursor()
    cur.execute('''
        CREATE TABLE IF NOT EXISTS test (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            text TEXT,
            source INTEGER,
            seq INTEGER
        )
    ''')
    while True:
        try:
            (sql, params), result_queue = work_queue.get()
            res = cur.execute(sql, params)
            con.commit()
            result_queue.put(res)
        except Exception as e:
            traceback.print_exc()

threading.Thread(target=sqlite_worker, daemon=True).start()

def execute_in_worker(sql, params):
    # you might not really need the results if you only use this
    # for writing unless you use something like https://www.sqlite.org/lang_returning.html
    result_queue = queue.Queue()
    work_queue.put(((sql, params), result_queue))
    return result_queue.get(timeout=5)

def insert_test_data(seq):
    time.sleep(random.randint(0, 100) / 100)
    execute_in_worker(
        'INSERT INTO test (text, source, seq) VALUES (?, ?, ?)',
        ['foo', threading.get_ident(), seq]
    )

threads = []
for i in range(10):
    thread = threading.Thread(target=insert_test_data, args=(i,))
    threads.append(thread)
    thread.start()

for thread in threads:
    thread.join()

for res in execute_in_worker('SELECT * FROM test', []):
    print(res)

# (1, 'foo', 139949462500928, 9)
# (2, 'foo', 139949496071744, 5)
# (3, 'foo', 139949479286336, 7)
# (4, 'foo', 139949487679040, 6)
# (5, 'foo', 139949854099008, 3)
# (6, 'foo', 139949470893632, 8)
# (7, 'foo', 139949862491712, 2)
# (8, 'foo', 139949845706304, 4)
# (9, 'foo', 139949879277120, 0)
# (10, 'foo', 139949870884416, 1)

Como puede ver, los datos se insertan desordenados, pero todavía se manejan uno por uno en un while círculo.

• https://docs.python.org/3/library/queue.html
• https://docs.python.org/3/library/threading.html#threading.Thread.join
• https://docs.python.org/3/library/threading.html#threading.get_ident