खोज…


Sqlalchemy और PyMySQL का उपयोग करना

from sqlalchemy import create_engine

cnx = create_engine('mysql+pymysql://username:password@server:3306/database').connect()
sql = 'select * from mytable'
df = pd.read_sql(sql, cnx)

डेटाफ़्रेम के लिए mysql को पढ़ने के लिए, बड़ी मात्रा में डेटा के मामले में

बड़े डेटा प्राप्त करने के लिए हम पांडा में जनरेटर का उपयोग कर सकते हैं और डेटा को चंक्स में लोड कर सकते हैं।

import pandas as pd
from sqlalchemy import create_engine
from sqlalchemy.engine.url import URL


# sqlalchemy engine
engine = create_engine(URL(
    drivername="mysql"
    username="user",
    password="password"
    host="host"
    database="database"
))

conn = engine.connect()

generator_df = pd.read_sql(sql=query,  # mysql query
                           con=conn,
                           chunksize=chunksize)  # size you want to fetch each time

for dataframe in generator_df:
    for row in dataframe:
        pass  # whatever you want to do


Modified text is an extract of the original Stack Overflow Documentation
के तहत लाइसेंस प्राप्त है CC BY-SA 3.0
से संबद्ध नहीं है Stack Overflow