jina-ai · hanxiao · Jun 29, 2021 · Jun 29, 2021 · Jun 29, 2021 · Jun 29, 2021
diff --git a/jina/flow/base.py b/jina/flow/base.py
@@ -8,6 +8,8 @@
 import threading
 import uuid
 import warnings
+import base64
+import urllib
 from collections import OrderedDict
 from contextlib import ExitStack
 from typing import Optional, Union, Tuple, List, Set, Dict, overload, Type
@@ -25,6 +27,7 @@
     typename,
     ArgNamespace,
     download_mermaid_url,
+    get_full_version,
 )
 from ..jaml import JAMLCompatible
 from ..logging.logger import JinaLogger
@@ -960,6 +963,8 @@ def start(self):
 
         self._build_level = FlowBuildLevel.RUNNING
         self._show_success_message()
+        if not self.args.no_telemetry:
+            self.register()
 
         return self
 
@@ -1554,3 +1559,23 @@ def update_network_interface(self, **kwargs):
         :param kwargs: new network settings
         """
         self._common_kwargs.update(kwargs)
+
+    def register(self) -> None:
+        """Register a Flow"""
+
+        def _register():
+            url = 'https://telemetry.jina.ai/'
+            try:
+                metas, envs = get_full_version()
+                data = base64.urlsafe_b64encode(
+                    json.dumps({**metas, **envs}).encode('utf-8')
+                )
+                req = urllib.request.Request(
+                    url, data=data, headers={'User-Agent': 'Mozilla/5.0'}
+                )
+                urllib.request.urlopen(req)
+
+            except:
+                pass
+
+        threading.Thread(target=_register, daemon=True).start()
diff --git a/jina/parsers/flow.py b/jina/parsers/flow.py
@@ -33,6 +33,13 @@ def mixin_flow_features_parser(parser):
     ''',
     )
 
+    gp.add_argument(
+ 
52D1
       '--no-telemetry',
+        action='store_true',
+        default=False,
+        help='If set, disable telemetry during the Flow creation.',
+    )
+
 
 def set_flow_parser(parser=None, with_identity=False):
     """Set the parser for the flow