我正在尝试设置一个脚本,该脚本将允许SQL查询和转换为pandas df。我在尝试使用DELETE FROM语句时遇到了一个问题。我目前有这样的东西:
import os
import boto3
import pandas as pd
import pandasql as ps
csv_file_path = 's3://bucket/folder/test.csv'
df = pd.read_csv(csv_file_path)
sql_mod = '''DELETE FROM df WHERE opt_out = 1'''
df1 = ps.sqldf(sql_mod, locals())
print(df1)
而且我正在从s3中读取的表看起来像这样
customer cust_id phone_nm addr date order opt_out
0 John 13251236 123-456-7890 2.893746e+10 8.760298e+07 298746746 0
1 Alex 234623476 234-567-8901 2.834760e+08 9.824770e+09 8746972 0
2 Amanda 151351 345-678-9012 2.090000e+14 9.750000e+11 9712975917 1
3 Carol 4236246 456-789-0123 9.284750e+07 7.346908e+10 9857897947 0
4 Carl 73457357 567-890-1234 2.934757e+09 3.746972e+08 97234967 1
5 Karen 15313513 678-9012 2.948769e+10 2.348760e+06 2436ou2 1
8 Scott 2573567 901-234-5678 9.723497e+07 9.723461e+07 9f29h34tin 0
但是我的delete语句似乎返回NULL DF。有没有一种方法可以使用保留标准SQL格式的pandas df运行SQL DELETE和INSERT?
我正在尝试设置一个脚本,该脚本将允许SQL查询和转换为pandas df。我在尝试使用DELETE FROM语句时遇到了一个问题。我目前有东西...
您需要select
语句而不是delete
语句。