बस, आपने एक डेटाफ्रेम बनाया है जो किए जाने वाले कार्य का एक नुस्खा है, लेकिन आपने इसे निष्पादित नहीं किया है। निष्पादित करने के लिए, आपको .compute() . पर कॉल करना होगा परिणाम पर।
ध्यान दें कि यहां आउटपुट वास्तव में डेटाफ़्रेम नहीं है, प्रत्येक विभाजन का मूल्यांकन None . होता है (क्योंकि to_sql कोई आउटपुट नहीं है), इसलिए इसे df.to_delayed . के साथ व्यक्त करना अधिक आसान हो सकता है , कुछ इस तरह
dto_sql = dask.delayed(pd.DataFrame.to_sql)
out = [dto_sql(d, 'table_name', db_url, if_exists='append', index=True)
for d in ddf.to_delayed()]
dask.compute(*out)
यह भी ध्यान दें, कि क्या आपको अच्छी समानता मिलती है, यह डेटाबेस ड्राइवर और डेटा सिस्टम पर ही निर्भर करेगा।
