Untitled

import os
import logging
import boto3
import paramiko


env = os.environ["env"]
region = os.environ["region"]
s3_client = boto3.client("s3")
session = boto3.session.Session()
ssh_client = paramiko.SSHClient()
LOGGER = logging.getLogger()
LOGGER.setLevel(logging.INFO)


def gamft_file_transfer(file_path: str, secrets: dict) -> None:
    LOGGER.info("Upload to GAMFT Server Started...")
    ssh_client.load_system_host_keys()
    transport = paramiko.Transport((os.environ["gamft_server"], 22))
    transport.connect(username=secrets["gamft_username"], password=secrets["gamft_password"])

    sftp = paramiko.SFTPClient.from_transport(transport)
    sftp.put(file_path, f"/outbox/{file_path.split('/')[-1]}")
    LOGGER.info("Upload to GAMFT Server Completed.")

    LOGGER.info(sftp.listdir(path="/outbox/"))
    os.remove(file_path)

    sftp.close()
    transport.close()
    ssh_client.close()