add example for data alignment

python/paddle_fl/mpc/examples/data_alignment/README.md

+## Data Alignment
+
+### 1. Introduction
+
+Data alignment is used for alignment of data set owned by multi parties without leaking any privacy information of data. Concretely, all data of data owners are numbered the same number for the same data. When align, all data owners input the set of data number and get a set of number for the intersection.
+
+
+
+### 2. Example
+
+Here is an example for data alignment between two parties. The `align.py` is a script used for  each party. The set of data number of the two parties are saved in `data_0.txt` and `data_1.txt` respectively. You can directly run `run.sh` for running this example in single machine.
+

python/paddle_fl/mpc/examples/data_alignment/align.py

+# Copyright (c) 2020 PaddlePaddle Authors. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""
+Data alignment.
+"""
+import argparse
+import paddle_fl.mpc.data_utils.alignment as alignment
+
+
+def parse_args():
+    """
+    Parse arguments.
+    """
+    parser = argparse.ArgumentParser(description=__doc__)
+    parser.add_argument("--party_id", type=int, help="the id of this party")
+    parser.add_argument("--endpoints", type=str,
+                        default='0:127.0.0.1:11111,1:127.0.0.1:22222',
+                        help="id:ip:port info")
+    parser.add_argument("--data_file", type=str, help="data file")
+    parser.add_argument("--is_receiver", action='store_true', help="whether is receiver")
+    args = parser.parse_args()
+    return args
+
+
+def do_align(args):
+    """
+    Do alignment.
+    """
+    # read data from file
+    input_set = set()
+    for line in open(args.data_file, 'r'):
+        input_set.add(line.strip())
+    # do alignment
+    result = alignment.align(input_set=input_set,
+                             party_id=args.party_id,
+                             endpoints=args.endpoints,
+                             is_receiver=args.is_receiver)
+    return result
+
+
+if __name__ == '__main__':
+    # use signal for interrupt from keyboard
+    import signal
+    signal.signal(signal.SIGINT, signal.SIG_DFL)
+
+    args = parse_args()
+    print('ARGUMENTS: party_id={}, endpoints={}, is_receiver={}, data_file={}'
+          .format(args.party_id, args.endpoints, args.is_receiver, args.data_file))
+    align_rst = do_align(args)
+    print("Alignment result is: {}".format(align_rst))

python/paddle_fl/mpc/examples/data_alignment/data_0.txt

+1
+2
+3
+4
+5
+6
+7
\ No newline at end of file

python/paddle_fl/mpc/examples/data_alignment/data_1.txt

+1
+2
+3
+4
+5
\ No newline at end of file

python/paddle_fl/mpc/examples/data_alignment/run.sh

+#!/bin/bash
+ENDPOINTS=0:127.0.0.1:11111,1:127.0.0.1:22222
+
+python align.py --party_id=0 --endpoints=$ENDPOINTS --data_file=data_0.txt 2>&1 >/dev/null &
+
+python align.py --party_id=1 --endpoints=$ENDPOINTS --data_file=data_1.txt --is_receiver