mysql load file using pipe

Question

Как использовать pipe to mysql load data infile с помощью python? Нижеследующее не работает. Местный файл ожиданий и, следовательно, не уверен, что из-за этого его не удается.

cat = Popen(["cat /Users/test/filename.out"], stdout=PIPE, bufsize=-1, shell=True) 
load = """load data local infile - into table %s fields terminated by '|' lines terminated by '\\n';""" % (tablename) 

with conn: 
    cursor = conn.cursor() 
    for line in cat.stdout: 
     cursor.execute(load.stdin.write(line)) 
cat.stdout.close() 
cat.wait() 
load.stdin.close() 
load.wait() 

Answer 1

Вы можете просто использовать имя файла как этот

load = """load data local infile '/Users/test/filename.out' into table %s fields terminated by '|' lines terminated by '\\n';""" % (tablename) 

with conn: 
    cursor = conn.cursor() 
    for line in cat.stdout: 
    cursor.execute(load.stdin.write(line)) 
cat.stdout.close() 
cat.wait() 
load.stdin.close() 
load.wait()