पोस्टग्रेज से पायथन में डेटा स्ट्रीम करना

यदि आप psycopg2 का उपयोग कर रहे हैं, तो आप एक नामित कर्सर का उपयोग करना चाहेंगे, अन्यथा यह एक ही बार में संपूर्ण क्वेरी डेटा को मेमोरी में पढ़ने का प्रयास करेगा।

cursor = conn.cursor("some_unique_name")
cursor.execute("SELECT aid FROM pgbench_accounts")
for record in cursor:
    something(record)

यह सर्वर से 2000 के बैच में रिकॉर्ड प्राप्त करेगा (itersize . का डिफ़ॉल्ट मान) ) और फिर उन्हें एक-एक करके लूप में पार्सल करें।