Добавление двух CSV-файлов по столбцам

Question

Предположим, у меня есть два CSV-файла, называемых A и B в Python.

A 's head выглядит следующим образом:

headerNameA1,headerNameA2 
1.12412424,1 
1,1 
1,1 
1,1 

B' s head выглядит следующим образом:

headerNameB1,headerNameB2 
1,1 
1,1 
1,1 
1,1 

Моя цель состоит в том, чтобы принять B и добавить его на A так, что A будет выглядеть :

headerNameA1,headerNameA2,headerNameB1,headerNameB2 
1,1,1.12412424,1 
1,1,1,1 
1,1,1,1 
1,1,1,1 

С другой вопрос, я спросил, вот код, который будет принимать A и B и объединить их в C:

import csv 
with open('A','rb') as f1, open('B','rb') as f2, open('out.csv','wb') as w: 
    writer = csv.writer(w) 
    r1,r2 = csv.reader(f1),csv.reader(f2) 
    while True: 
     try: 
      writer.writerow(next(r1)+next(r2)) 
     except StopIteration: 
      break 

Однако цель этого вопроса просто добавить B на задней A.

Это необходимо, если размер A таков, что это слишком дорого для места на диске, чтобы сделать его копию как файл C перед удалением A.

Баш решение под названием через os.system приемлемо

Answer 1

Если вы получаете два файла ручки для одного файла - один в режиме «чтения», один в режиме «обновления» (r+b), та же стратегия должна Работа.

from itertools import izip 
import csv 
with open('A','rb') as f1, open('B','rb') as f2, open('A','r+b') as w: 
    writer = csv.writer(w) 
    for r1,r2 in izip(csv.reader(f1),csv.reader(f2)): 
     writer.writerow(r1+r2) 

Если возможно, я рекомендовал бы против такого рода вещей и просто явно записывать в третий файл.

Answer 2

Возможно, вам удастся с именованным трубой. У вас запущен процесс Python, который создает канал и открывает его в режиме записи. Затем он выводит на то, что мутированная конкатенация CSV-файлов в столбце (аналогично тому, что у вас есть) уже ... Когда другой процесс начинает читать этот файл, он сможет потреблять данные, но файл фактически не сохраняется на сервере это просто по требованию. Когда «файл» потребляется, в нем ничего не будет, и любая попытка доступа к нему блокируется до тех пор, пока другой процесс не запишет на другой конец.

фиктивный коду - потребуется больше продуманные обработки и т.д. исключение ...:

import os 
from itertools import izip 

a = 'abcdef' # File A's rows 
b = 'ghijkl' # File B's rows 

outname = 'joined' 

try: 
    os.unlink(outname) 
    os.mkfifo(outname) 
except OSError: 
    pass 

with open(outname, 'w') as fout: 
    for items in izip(a, b): 
     fout.write(''.join(items) + '\n') # Do "real" write here instead... 
    os.unlink(outname) 

Что-то еще, что открывает «файл» в режиме чтения и потребляет его для извлечения данных. Это должно работать, если этот процесс не должен иметь «физические файлы» ...