FedLearner Framework and Core Dependency RA-TLS Configuration (#1097)

* Meituan HDFS Access Without Proxy for Kerberos Authentication * Meituan HDFS Access Without Proxy for Kerberos Authentication * 1. FedLearner Framework and Core Dependency RA-TLS Configuration To ensure code consistency and implement hash signature-based remote attestation for the FedLearner framework and its core dependencies, an environment variable has been introduced in Gramine that prevents the generation of .pyc files. 2. Gramine Template Configuration for FedLearner The Gramine template configuration has been updated to include the code locations for the FedLearner framework and some essential dependencies. This addition facilitates bidirectional remote attestation between parties. 3. Meituan HDFS File Path Management Optimization The code responsible for handling file paths in Meituan's Hadoop Distributed File System (HDFS) has been migrated from the main entry point to be processed by the master node. This change aims to prevent file read and write conflicts that could arise from multiple workers operating simultaneously. * Fix gramine allowed files lib risk, add sub path to allowed files * Regarding the TensorFlow API, it allows the addition of specific files that change with each compilation to the Gramine configuration, rather than the entire API folder. --------- Co-authored-by: huangxu17 <[email protected]>
bytedance · Apr 15, 2024 · f905579 · f905579
1 parent 0e267b8
commit f905579
Show file tree

Hide file tree

Showing 4 changed files with 451 additions and 46 deletions.
diff --git a/fedlearner-sgx-dev.dockerfile b/fedlearner-sgx-dev.dockerfile
@@ -6,6 +6,8 @@ ENV DEBIAN_FRONTEND=noninteractive
 ENV INSTALL_PREFIX=/usr/local
 ENV LD_LIBRARY_PATH=${INSTALL_PREFIX}/lib:${INSTALL_PREFIX}/lib/x86_64-linux-gnu:${LD_LIBRARY_PATH}
 ENV PATH=${INSTALL_PREFIX}/bin:${LD_LIBRARY_PATH}:${PATH}
+# For Gramine RA-TLS
+ENV PYTHONDONTWRITEBYTECODE=1
 
 # Add steps here to set up common dependencies
 RUN apt-get update \
@@ -60,8 +62,8 @@ RUN apt-get install -y libcurl4-openssl-dev libprotobuf-c-dev python3-protobuf p
 RUN apt-get install -y libgmp-dev libmpfr-dev libmpc-dev libisl-dev nasm protobuf-compiler
 
 RUN ln -s /usr/bin/python3 /usr/bin/python \
-    && pip3 install --upgrade pip \
-    && pip3 install toml meson pyelftools
+    && pip3 install --no-compile --upgrade pip -i https://mirrors.aliyun.com/pypi/simple/ \
+    && pip3 install --no-compile toml meson pyelftools -i https://mirrors.aliyun.com/pypi/simple/
 
 RUN git clone https://github.com/analytics-zoo/gramine ${GRAMINEDIR} \
     && cd ${GRAMINEDIR} \
@@ -101,17 +103,17 @@ ENV GRPC_VERSION=v1.38.1
 
 RUN git clone --recurse-submodules -b ${GRPC_VERSION} https://github.com/grpc/grpc ${GRPC_PATH}
 
-RUN pip3 install --upgrade pip \
-    && pip3 install -r ${GRPC_PATH}/requirements.txt
+RUN pip3 install --no-compile --upgrade pip -i https://mirrors.aliyun.com/pypi/simple/ \
+    && pip3 install --no-compile -r ${GRPC_PATH}/requirements.txt -i https://mirrors.aliyun.com/pypi/simple/
 
 # Tensorflow dependencies
 ENV BAZEL_VERSION=3.1.0
 ENV TF_VERSION=v2.4.2
 ENV TF_BUILD_PATH=/tf/src
 ENV TF_BUILD_OUTPUT=/tf/output
 
-RUN pip3 install --upgrade pip \
-    && pip3 install numpy keras_preprocessing
+RUN pip3 install --no-compile --upgrade pip -i https://mirrors.aliyun.com/pypi/simple/ \
+    && pip3 install --no-compile numpy keras_preprocessing -i https://mirrors.aliyun.com/pypi/simple/
 
 RUN wget "https://github.com/bazelbuild/bazel/releases/download/${BAZEL_VERSION}/bazel_${BAZEL_VERSION}-linux-x86_64.deb" \
     && dpkg -i bazel_*.deb
@@ -127,7 +129,7 @@ RUN apt-get install -y libmysqlclient-dev
 COPY sgx/grpc/common ${GRPC_PATH}
 COPY sgx/grpc/v1.38.1 ${GRPC_PATH}
 
-RUN pip3 install 'cython==0.29.36'
+RUN pip3 install --no-compile 'cython==0.29.36' -i https://mirrors.aliyun.com/pypi/simple/
 RUN ${GRPC_PATH}/build_python.sh
 
 # Build tensorflow
@@ -150,17 +152,17 @@ RUN if [ -f ${FEDLEARNER_PATH}/docker/hadoop-mt-2.7.0.tar.gz ]; then mkdir -p /o
 # For meituan hadoop auth
 RUN apt-get install -y libkrb5-dev openjdk-8-jdk
 
-RUN pip3 install --upgrade pip \
-    && pip3 install -r ${FEDLEARNER_PATH}/requirements.txt -i https://mirrors.aliyun.com/pypi/simple/
+RUN pip3 install --no-compile --upgrade pip -i https://mirrors.aliyun.com/pypi/simple/ \
+    && pip3 install --no-compile  -r ${FEDLEARNER_PATH}/requirements.txt -i https://mirrors.aliyun.com/pypi/simple/
 
 RUN cd ${FEDLEARNER_PATH} \
     && make protobuf \
     && python3 setup.py bdist_wheel \
-    && pip3 install ./dist/*.whl
+    && pip3 install --no-compile ./dist/*.whl
 
 # Re-install tensorflow, uninstall tensorflow_io, mock it
 RUN pip3 uninstall -y tensorflow tensorflow-io \
-    && pip3 install ${TF_BUILD_OUTPUT}/*.whl
+    && pip3 install --no-compile ${TF_BUILD_OUTPUT}/*.whl
 
 # Re-install fedlearner plugin
 RUN cd ${FEDLEARNER_PATH} \
@@ -170,7 +172,7 @@ RUN cd ${FEDLEARNER_PATH} \
 
 # Re-install grpcio
 RUN pip3 uninstall -y grpcio \
-    && pip3 install ${GRPC_PATH}/dist/grpcio*.whl
+    && pip3 install --no-compile ${GRPC_PATH}/dist/grpcio*.whl
 
 # For debug
 RUN apt-get install -y strace gdb ctags vim
@@ -182,6 +184,11 @@ COPY sgx/configs /
 RUN echo "enabled=0" > /etc/default/apport
 RUN echo "exit 0" > /usr/sbin/policy-rc.d
 
+# For gramine ra-tls
+RUN dpkg --remove --force-depends libgtk2.0-0 \
+    && pip3 uninstall -y numpy keras_preprocessing protobuf \
+    && pip3 install --no-compile numpy keras_preprocessing protobuf -i https://mirrors.aliyun.com/pypi/simple/
+
 # Clean tmp files
 RUN apt-get clean all \
     && rm -rf /var/lib/apt/lists/* \

diff --git a/fedlearner/trainer/trainer_worker.py b/fedlearner/trainer/trainer_worker.py
@@ -232,6 +232,33 @@ def _run_master(role,
         cluster_server = ClusterServer(cluster_spec, "master",
                                        server_port=args.server_port)
 
+    # use Meituan hadoop
+    # first：convert Meituan HDFS path to local storage path, if local exit psi result file, user local file
+    # second：if local not exit psi result file，from Meituan HDFS download to local
+    if args.using_mt_hadoop:
+        data_path = args.data_path
+        if data_path:
+            local_data_path = get_local_temp_path(data_path)
+            if not exists(local_data_path):
+                data_path = mt_hadoop_download(data_path)
+            else:
+                data_path = local_data_path
+            args.data_path = data_path
+
+        checkpoint_path = args.checkpoint_path
+        if checkpoint_path:
+            args.checkpoint_path = get_local_temp_path(checkpoint_path)
+
+        load_checkpoint_path = args.load_checkpoint_path
+        if load_checkpoint_path:
+            args.load_checkpoint_path = get_local_temp_path(load_checkpoint_path)
+            if not exists(args.load_checkpoint_path):
+                mt_hadoop_download(load_checkpoint_path)
+
+        export_path = args.export_path
+        if export_path:
+            args.export_path = get_local_temp_path(export_path)
+
     checkpoint_filename_with_path = _get_checkpoint_filename_with_path(args)
     data_visitor = _create_data_visitor(args)
     master_factory = LeaderTrainerMaster \
@@ -479,33 +506,6 @@ def train(role,
     if not isinstance(role, str) or role.lower() not in (LEADER, FOLLOER):
         raise ValueError("--role must set one of %s or %s"%(LEADER, FOLLOER))
 
-    # use Meituan hadoop
-    # first：convert Meituan HDFS path to local storage path, if local exit psi result file, user local file
-    # second：if local not exit psi result file，from Meituan HDFS download to local
-    if args.using_mt_hadoop:
-        data_path = args.data_path
-        if data_path:
-            local_data_path = get_local_temp_path(data_path)
-            if not exists(local_data_path):
-                data_path = mt_hadoop_download(data_path)
-            else:
-                data_path = local_data_path
-            args.data_path = data_path
-
-        checkpoint_path = args.checkpoint_path
-        if checkpoint_path:
-            args.checkpoint_path = get_local_temp_path(checkpoint_path)
-
-        load_checkpoint_path = args.load_checkpoint_path
-        if load_checkpoint_path:
-            args.load_checkpoint_path = get_local_temp_path(load_checkpoint_path)
-            if not exists(args.load_checkpoint_path):
-                mt_hadoop_download(load_checkpoint_path)
-
-        export_path = args.export_path
-        if export_path:
-            args.export_path = get_local_temp_path(export_path)
-
     if args.loglevel:
         fl_logging.set_level(args.loglevel)
 

diff --git a/setup.py b/setup.py
@@ -11,8 +11,7 @@
 
 def get_version():
     base = "1.5"
-    day = time.strftime('%Y%m%d', time.localtime())
-    return '%s-dev%s'%(base, day)
+    return '%s-dev' % base
 
 setup(
     name='fedlearner',