big-trot,
поинтересуйтесь, как работают системы триггер-репликации.
по сравнению с вашим случаем они всего-то отличаются тем, что там таблица назначения (что не существенно, на самом деле в самом решении, но маскирует некоторые допущения, которые потребуются в вашем случае) совпадает с таблицей источника по структуре.


т.е. вам нужно обрабатывать 2 случая.
1. передача снепшота, и первичная синхронизация. <тут всё в лоб, часами>
2. передача (и обработка по месту назначения) событий через очередь. <тут экономия на инкрементальности>
но раскладывать это не в совпадающую структуру (как при репликации), а в новую.



естественно, это выполнимо, если есть хотя бы намек на однозначность отображения структуры А на структуру Б (взаимной, при одностороннем обмене данными, не требуется. При двустороннем обмене данными всё становится много сложнее, как только выясняется, что одно и то же данное надо согласовывать в обе стороны (коллизии мастер-мастер репликации, умноженные на несовпадение структур, т.е. на сопутствующие преобразования А->Б | Б->А)).


PS лондайст например использует для передачи данных свой текстовый формат, сильно похожий на hstore. т.ч. рекомендую hstore для п.2. Для п.1. лондайст просто копирует данные командой COPY (простое сравнение строк возможно в силу совпадения структур. в вашем случае наверное можно схоже, но перед COPY на стороне выгрузки(А) провести преобразование к структуре (Б).