ingestor_prep.py

import os

import paramiko

def sftp_connection():
    username = os.environ['sftp_users_emg'].split(':')[0]
    password = os.environ['sftp_users_emg'].split(':')[1]
    transport = paramiko.Transport(('docker', 2223))
    transport.connect(username=username, password=password)
    sftp = paramiko.SFTPClient.from_transport(transport)
    sftp.put('./testing/tpzonlineitem.xml', '/data/from/fepd/tpzonlineitem.xml')


sftp_connection()