通用型 CFS 实践指南

mount -t nfs -o vers=4.0,proto=tcp,noac,noresvport 10.XX.XX.XX:/ /localfolder

import os
import fcntl

O_WRONLY = os.O_WRONLY  # 以只写方式打开文件
O_APPEND = os.O_APPEND  # 以追加方式打开文件
O_DIRECT = getattr(os, 'O_DIRECT', 0o40000)  # 尝试获取系统的 O_DIRECT 常量，如果不存在则设置为默认值 0o40000
SEEK_END = os.SEEK_END  # 以文件尾为参考点

 # 假定并发写入的文件为 file1
filename = '/root/cfs/file1' 

try:
    fd = os.open(filename, O_WRONLY | O_APPEND | O_DIRECT)
    
    # 尝试获取文件锁
    try:
        fcntl.flock(fd, fcntl.LOCK_EX | fcntl.LOCK_NB)
        print("Successfully acquired lock")
        
        # 定位到文件尾
        os.lseek(fd, 0, SEEK_END)
        
        # 写入数据
        data = b"hello world"
        os.write(fd, data)
        
    except BlockingIOError:
        print("File is locked by another process")
        # 如果文件被锁，则退出
        exit(1)
    finally:
        # 释放文件锁
        fcntl.flock(fd, fcntl.LOCK_UN)
        print("Lock released")
        
finally:
    if 'fd' in locals():
        os.close(fd)