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.1.tar.gz (14.3 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.1-py3-none-any.whl (13.8 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: core_ftp-3.0.1.tar.gz
  • Upload date:
  • Size: 14.3 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.1.tar.gz
Algorithm Hash digest
SHA256 b0aa9e787e170a31791c481dbfe18b80fa8acd62821f96f506397f4416318eea
MD5 9b046261b6e7bf6217308489e5745f68
BLAKE2b-256 0a61a7bd57a5a2d53831d5cb5cbb4f2f6aa7c73c6ed9724b722ca6e202cc4398

See more details on using hashes here.

File details

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

File metadata

  • Download URL: core_ftp-3.0.1-py3-none-any.whl
  • Upload date:
  • Size: 13.8 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.1-py3-none-any.whl
Algorithm Hash digest
SHA256 1bf6572b465c2c7011cfcdc77a8f4112308b3ed5eb66a34e8b4250e621bbdeb7
MD5 c8a86393287b9977ce5acc89eb684601
BLAKE2b-256 7ccc0b25822bbddf7aa5fdc43db7f7b13dc8db9d91e747cd5b81dfc2d441163d

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