Festlegen der Zeitüberschreitung bei der Datenbankverbindung in Python

Question

Ich erstelle eine RESTful-API, die auf die Datenbank zugreifen muss. Ich benutze Restish, Oracle und SQLAlchemy. Ich versuche jedoch, meine Frage so allgemein wie möglich zu formulieren, ohne Restish oder andere Web-APIs zu berücksichtigen.

Ich möchte in der Lage sein, ein Timeout für eine Verbindung festzulegen, die eine Abfrage ausführt. Auf diese Weise wird sichergestellt, dass Abfragen mit langer Laufzeit abgebrochen und die Verbindung verworfen (oder wiederverwendet) wird. Dieses Abfragetimeout kann ein globaler Wert sein, dh ich muss es nicht nach Abfrage oder Verbindungserstellung ändern.

den folgenden Code Gegeben:

import cx_Oracle 
import sqlalchemy.pool as pool 

conn_pool = pool.manage(cx_Oracle) 
conn = conn_pool.connect("username/p4ss@dbname") 
conn.ping() 

try: 
    cursor = conn.cursor() 
    cursor.execute("SELECT * FROM really_slow_query") 
    print cursor.fetchone() 
finally: 
    cursor.close() 

Wie kann ich den obigen Code ändern auf eine Abfrage-Timeout zu setzen? Wird diese Zeitüberschreitung auch für die Verbindungserstellung gelten?

Dies ist ähnlich wie die Methode setQueryTimeout (int seconds) von java.sql.Statement in Java.

Dank

Answer 1

Sie bei der Einrichtung PROFILE s in Oracle aussehen könnte die Anfragen nach einer bestimmten Anzahl von logical_reads_per_call und/oder cpu_per_call

Answer 2

Timing-Out mit dem Systemalarm

hier zu beenden wie man das Betriebssystem Timout verwendet, um dies zu tun. Es ist generisch und funktioniert für andere Dinge als Oracle.

Answer 3

für die Abfrage können Sie auf Timer und conn.cancel() aufrufen.

etwas in diese Richtung:

t = threading.Timer(timeout,conn.cancel) 
t.start() 
cursor = conn.cursor() 
cursor.execute(query) 
res = cursor.fetchall() 
t.cancel() 

Answer 4

In Linux siehe /etc/oracle/sqlnet.ora,

sqlnet.outbound_connect_timeout= value

auch Möglichkeiten:

tcp.connect_timeout und sqlnet .expire_time, viel Glück!