如何动态传递Spanner batch.insert_or_update Python API的列名

如何解决如何动态传递Spanner batch.insert_or_update Python API的列名

我正在使用database.snapshot（）从扳手读取数据，并且尝试使用执行batch.insert_or_update的结果集（实质上，我正在使用2个扳手API调用执行合并操作）。我找不到任何有关如何使用database.snapshot（）中的结果集设置列的文档。我尝试将变量用于列选项也不起作用。如果我正在使用数据框（从sqlserver读取），并且能够使用df.columns选项动态设置此值。感谢有人能对此有所启发。

这就是我尝试过的。我不是python专家，所以如果我做的很蠢，请随时分享您的想法。我正在获取一个列表并将其转换为数据框，如果看起来很奇怪，请知道我正在尝试构建一个小的通用函数，该函数可以运行多线程并可以用于在任何表上执行insert_update。>

```
sql_stmt = "select Col1,Col2,Col3,Col4 from Table1 where Col1 > 1000 " 

spanner_client = spanner.Client()
instance = spanner_client.instance(instance_id)
database = instance.database(database_id)

with database.snapshot() as snapshot:
     results = snapshot.execute_sql(sql_stmt)

df = pd.DataFrame(results)
df.columns = results.Metadata
columns_list = "('Col1','Col2','Col3','Col4')"
with database.batch() as batch:
      batch.insert_or_update(
      table=tablename,columns=columns_list,values=df.values.tolist())
```
   

解决方法

我发现了问题，这是更正后的代码。 column_list变量不需要引号。

sql_stmt = "select Col1,Col2,Col3,Col4 from Table1 where Col1 > 1000 " 

spanner_client = spanner.Client()
instance = spanner_client.instance(instance_id)
database = instance.database(database_id)

with database.snapshot() as snapshot:
     results = snapshot.execute_sql(sql_stmt)

df = pd.DataFrame(results)
df.columns = results.metadata
columns_list = ('Col1','Col2','Col3','Col4')
with database.batch() as batch:
      batch.insert_or_update(
      table=tablename,columns=columns_list,values=df.values.tolist())