Skip to main content

This project/library contains common elements related to FTP connections...

Project description

# core-ftp

This project/library provides a comprehensive set of common components and interfaces designed to facilitate and streamline FTP connections, ensuring efficient communication and data transfer…


Python Versions License Pipeline Status Docs Status Security

Installation

Install from PyPI using pip:

pip install core-ftp
uv pip install core-ftp  # Or using UV...

Features

SFTP Client

  • Simplified SFTP connection management with context manager support

  • Multiple authentication methods:

    • Password-based authentication

    • SSH private key authentication with optional passphrase

    • Customizable transport and connection parameters

  • Comprehensive file operations:

    • List files and directories with detailed attributes

    • Upload files from local filesystem or file-like objects

    • Download files to local filesystem

    • Delete files and directories

    • Change and retrieve current working directory

  • Built-in error handling with custom exceptions

  • Automatic resource cleanup

ETL Support

  • Abstract base class for SFTP-based ETL tasks

  • Seamless integration with core-etl framework

  • File filtering capabilities:

    • Filter by file extension

    • Filter by filename prefix

    • Time-based filtering with delay options

  • Optional automatic file cleanup after successful processing

Examples

Password authentication

from core_ftp.clients.sftp import SftpClient, SftpConnectionConfig

config = SftpConnectionConfig(host="test.rebex.net", port=22, user="demo", password="password")

with SftpClient(config) as client:
    for name, attr in client.list_files("/"):
        print(name, attr)

SSH key authentication

from core_ftp.clients.sftp import SftpClient, SftpConnectionConfig

config = SftpConnectionConfig(host="localhost", port=23, user="foo", private_key_path="/path/to/id_rsa")

with SftpClient(config) as client:
    client.download_file("remote/file.txt", "/local/file.txt")

Upload a file

from core_ftp.clients.sftp import SftpClient, SftpConnectionConfig

config = SftpConnectionConfig(host="localhost", user="foo", password="pass")

with SftpClient(config) as client:
    client.chdir("/upload")
    client.upload_file("/local/report.csv", "report.csv", confirm=True)

ETL task (file-based processing)

from core_ftp.clients.sftp import SftpConnectionConfig
from core_ftp.etls.file_based import IBaseEtlFromFtpFile, SftpFileConfig

class DataProcessor(IBaseEtlFromFtpFile):
    @classmethod
    def registered_name(cls) -> str:
        return "DataProcessor"

    def process_file(self, path: str, **kwargs):
        print(f"Processing {path}")

DataProcessor(
    connection=SftpConnectionConfig(host="data.server.com", user="admin", password="secret"),
    file_config=SftpFileConfig(path="/data/csv", file_ext=".csv", delete_file_on_success=True),
).execute()

Local SFTP server using Docker

Functional tests require two local SFTP servers running via Docker (atmoz/sftp): one for password authentication (port 22) and one for SSH key authentication (port 23).

1. Password authentication (port 22)

docker run \
  --mount type=bind,source="$(pwd)/tests/resources/upload",target=/home/foo/upload \
  -p 22:22 -d atmoz/sftp foo:pass:::upload

2. SSH key authentication (port 23)

docker run \
  --mount type=bind,source="$(pwd)/tests/resources/ssh_keys/id_rsa.pub",target=/home/foo/.ssh/keys/id_rsa.pub,readonly \
  --mount type=bind,source="$(pwd)/tests/resources/upload",target=/home/foo/upload \
  -p 23:22 -d atmoz/sftp foo::1001

Run functional tests

python manager.py run-tests --test-type functional --pattern "*.py"

Quick Start

Installation

Install the package:

pip install core-ftp
uv pip install core-ftp     # Or using UV...
pip install -e ".[dev]"     # For development...

Setting Up Environment

  1. Install required libraries:

pip install --upgrade pip
pip install virtualenv
  1. Create Python virtual environment:

virtualenv --python=python3.12 .venv
  1. Activate the virtual environment:

source .venv/bin/activate

Install packages

pip install .
pip install -e ".[dev]"

Check tests and coverage

python manager.py run-tests
python manager.py run-coverage

Contributing

Contributions are welcome! Please:

  1. Fork the repository

  2. Create a feature branch

  3. Write tests for new functionality

  4. Ensure all tests pass: pytest -n auto

  5. Run linting: pylint core_ftp

  6. Run security checks: bandit -r core_ftp

  7. Submit a pull request

License

This project is licensed under the MIT License. See the LICENSE file for details.

Support

For questions or support, please open an issue on GitLab or contact the maintainers.

Authors

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

core_ftp-3.0.2.tar.gz (14.4 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

core_ftp-3.0.2-py3-none-any.whl (14.0 kB view details)

Uploaded Python 3

File details

Details for the file core_ftp-3.0.2.tar.gz.

File metadata

  • Download URL: core_ftp-3.0.2.tar.gz
  • Upload date:
  • Size: 14.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for core_ftp-3.0.2.tar.gz
Algorithm Hash digest
SHA256 7e6831bfbfb76025852ab62fe48eba85342e16e2987c44d3320318244d6b3549
MD5 11714ba78d6bb789d8c25c57ecfbb3bb
BLAKE2b-256 63a8f40fe20423ad811f15fdc9ba7ca869c7d060d39f5bd2d8a43c8a00e7e9f5

See more details on using hashes here.

File details

Details for the file core_ftp-3.0.2-py3-none-any.whl.

File metadata

  • Download URL: core_ftp-3.0.2-py3-none-any.whl
  • Upload date:
  • Size: 14.0 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for core_ftp-3.0.2-py3-none-any.whl
Algorithm Hash digest
SHA256 43aadde290aa677810584f486b1cea9e99b795550ae667747a9ee4265a367fe2
MD5 15b6cc96d7aa2d24ccb94c630cac03ba
BLAKE2b-256 2d7ac5c35295a498b30776fe62a9dfb17a9c070e62955ccdf48f5c0468f91426

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page