pip install fastdfs-client

cd python_client
python setup.py install

from fdfs import Client, ClientConfig

# Create client configuration
config = ClientConfig(
    tracker_addrs=['192.168.1.100:22122', '192.168.1.101:22122'],
    max_conns=10,
    connect_timeout=5.0,
    network_timeout=30.0
)

# Initialize client
client = Client(config)

# Upload a file
file_id = client.upload_file('test.jpg')
print(f"File uploaded: {file_id}")

# Download the file
data = client.download_file(file_id)
print(f"Downloaded {len(data)} bytes")

# Delete the file
client.delete_file(file_id)
print("File deleted")

# Close client
client.close()

from fdfs import Client, ClientConfig

config = ClientConfig(tracker_addrs=['192.168.1.100:22122'])

with Client(config) as client:
    file_id = client.upload_buffer(b'Hello, FastDFS!', 'txt')
    data = client.download_file(file_id)
    client.delete_file(file_id)

data = b'Hello, FastDFS!'
file_id = client.upload_buffer(data, 'txt')

metadata = {
    'author': 'John Doe',
    'date': '2025-01-15',
    'version': '1.0'
}
file_id = client.upload_file('document.pdf', metadata)

client.download_to_file(file_id, '/path/to/save/file.jpg')

# Download bytes from offset 100, length 1024
data = client.download_file_range(file_id, offset=100, length=1024)

# Upload appender file
file_id = client.upload_appender_file('log.txt')

# Note: Append, modify, and truncate operations require
# storage server configuration to support appender files

from fdfs.types import MetadataFlag

# Set metadata (overwrite)
metadata = {
    'width': '1920',
    'height': '1080'
}
client.set_metadata(file_id, metadata, MetadataFlag.OVERWRITE)

# Get metadata
meta = client.get_metadata(file_id)
print(meta)

# Merge metadata
new_meta = {'author': 'Jane Doe'}
client.set_metadata(file_id, new_meta, MetadataFlag.MERGE)

info = client.get_file_info(file_id)
print(f"Size: {info.file_size}")
print(f"Create time: {info.create_time}")
print(f"CRC32: {info.crc32}")
print(f"Source IP: {info.source_ip_addr}")

exists = client.file_exists(file_id)
print(f"File exists: {exists}")

config = ClientConfig(
    # Tracker server addresses (required)
    tracker_addrs=['192.168.1.100:22122'],
    
    # Maximum connections per tracker (default: 10)
    max_conns=10,
    
    # Connection timeout in seconds (default: 5.0)
    connect_timeout=5.0,
    
    # Network I/O timeout in seconds (default: 30.0)
    network_timeout=30.0,
    
    # Connection pool idle timeout in seconds (default: 60.0)
    idle_timeout=60.0,
    
    # Retry count for failed operations (default: 3)
    retry_count=3
)

from fdfs.errors import (
    FileNotFoundError,
    NoStorageServerError,
    ConnectionTimeoutError,
    NetworkError,
    InvalidFileIDError
)

try:
    file_id = client.upload_file('test.txt')
except FileNotFoundError:
    print("Local file not found")
except NoStorageServerError:
    print("No storage server available")
except ConnectionTimeoutError:
    print("Connection timeout")
except NetworkError as e:
    print(f"Network error: {e}")

import threading

def upload_file(client, filename):
    file_id = client.upload_file(filename)
    print(f"Uploaded: {file_id}")

config = ClientConfig(tracker_addrs=['192.168.1.100:22122'])
client = Client(config)

threads = []
for i in range(10):
    t = threading.Thread(target=upload_file, args=(client, f'file{i}.txt'))
    threads.append(t)
    t.start()

for t in threads:
    t.join()

client.close()

# Unit tests
python -m pytest tests/

# With coverage
python -m pytest tests/ --cov=fdfs --cov-report=html

# Integration tests (requires running FastDFS cluster)
export FASTDFS_TRACKER_ADDR=192.168.1.100:22122
python -m pytest tests/test_integration.py

# Clone repository
git clone https://github.com/happyfish100/fastdfs.git
cd fastdfs/python_client

# Create virtual environment
python -m venv venv
source venv/bin/activate  # On Windows: venv\Scripts\activate

# Install development dependencies
pip install -e ".[dev]"

# Format code
black fdfs tests examples

# Sort imports
isort fdfs tests examples

# Lint
flake8 fdfs tests examples

# Type checking
mypy fdfs