Đặt thời gian chờ kết nối cơ sở dữ liệu bằng Python

Question

Tôi đang tạo một API RESTful cần truy cập cơ sở dữ liệu. Tôi đang sử dụng Restish, Oracle và SQLAlchemy. Tuy nhiên, tôi sẽ cố gắng đặt câu hỏi của mình một cách rộng rãi nhất có thể, mà không cần tính đến các API của Restish hoặc các API web khác.

Tôi muốn có thể đặt thời gian chờ cho kết nối thực hiện truy vấn. Điều này đảm bảo rằng các truy vấn chạy dài bị bỏ qua và kết nối bị loại bỏ (hoặc tái chế). Thời gian chờ truy vấn này có thể là một giá trị toàn cầu, có nghĩa là, tôi không cần phải thay đổi nó cho mỗi truy vấn hoặc tạo kết nối.

Với đoạn mã sau:

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() 

Làm thế nào tôi có thể sửa đổi các mã trên để thiết lập một thời gian chờ truy vấn trên nó? Thời gian chờ này cũng sẽ áp dụng cho việc tạo kết nối?

Điều này tương tự với phương thức setQueryTimeout (int giây) của java.sql.Statement trong Java.

Cảm ơn

Answer 1

Bạn có thể nhìn vào thiết lập PROFILE s trong Oracle để chấm dứt các truy vấn sau khi một số lượng nhất định logical_reads_per_call và/hoặc cpu_per_call

Answer 2

Timing Out với hệ thống báo động

Dưới đây là cách sử dụng thời gian chờ của hệ điều hành để thực hiện việc này. Đó là chung chung, và làm việc cho những thứ khác ngoài Oracle.

import signal 
class TimeoutExc(Exception): 
    """this exception is raised when there's a timeout""" 
    def __init__(self): Exception.__init__(self) 
def alarmhandler(signame,frame): 
    "sigalarm handler. raises a Timeout exception""" 
    raise TimeoutExc() 

nsecs=5 
signal.signal(signal.SIGALRM, alarmhandler) # set the signal handler function 
signal.alarm(nsecs)       # in 5s, the process receives a SIGALRM 
try: 
    cx_Oracle.connect(blah blah)    # do your thing, connect, query, etc 
    signal.alarm(0)       # if successful, turn of alarm 
except TimeoutExc: 
    print "timed out!"      # timed out!! 

Answer 3

cho truy vấn, bạn có thể xem cuộc gọi hẹn giờ và conn.cancel().

cái gì đó trong những dòng:

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

Answer 4

Trong linux thấy /etc/oracle/sqlnet.ora,

sqlnet.outbound_connect_timeout= value

cũng có các tùy chọn:

tcp.connect_timeout và sqlnet .expire_time, chúc may mắn!