关于Taipy中read_fct与write_fct的参数、返回值及示例问询

read_fct 要求 #

• 参数：无额外输入参数，函数无需接收外部传入值
• 返回格式：返回Taipy可解析的数据集即可，比如你已实现的元组列表，也支持字典列表、Pandas DataFrame等格式

示例（你的现有实现参考）：

import sqlite3

def my_read_fct():
    conn = sqlite3.connect('mydatabase.db')
    cursor = conn.cursor()
    cursor.execute("SELECT id, name FROM target_table")
    data = cursor.fetchall()  # 元组列表格式，如[(1, "张三"), (2, "李四")]
    conn.close()
    return data

write_fct 要求 #

• 参数：必须接收一个参数，该参数对应需要写入存储的数据集（格式与read_fct返回的格式完全一致，比如你的元组列表）
• 返回要求：无需返回值（返回None即可），核心是完成数据写入目标存储的操作

对应你的read_fct的write_fct示例 #

import sqlite3

def my_write_fct(data):
    # data即为传入的元组列表，格式与read_fct返回一致
    conn = sqlite3.connect('mydatabase.db')
    cursor = conn.cursor()
    
    # 示例操作：清空目标表（根据业务需求可选）
    cursor.execute("DELETE FROM target_table")
    # 批量插入数据，适配元组列表格式
    cursor.executemany("INSERT INTO target_table (id, name) VALUES (?, ?)", data)
    
    conn.commit()
    conn.close()
    # 无需返回任何内容

绑定到Data Node的示例 #

将上述函数绑定到Taipy的Data Node即可：

from taipy.core import DataNode

# 创建通用类型Data Node，指定读写函数
target_data_node = DataNode(
    read_fct=my_read_fct,
    write_fct=my_write_fct,
    type="generic"
)

内容的提问来源于stack exchange，提问作者Rym Guerbi Michaut