add tf_graph_tool

Author: nbcsm

tools/tf_graph_tool.py

@@ -0,0 +1,198 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT license.
+
+""" Tool for common tf graph operations. """
+
+from __future__ import division
+from __future__ import print_function
+
+import argparse
+import logging
+import os
+import sys
+
+from google.protobuf import text_format
+import tensorflow as tf
+from tensorflow.python.framework import graph_util
+
+# pylint: disable=missing-docstring
+
+logging.basicConfig(stream=sys.stdout, format='[%(asctime)s] %(levelname)s: %(message)s', level=logging.INFO)
+
+
+def get_file_name(path):
+    return os.path.basename(path)
+
+
+def get_file_name_without_ext(path):
+    return '.'.join(get_file_name(path).split('.')[:-1])
+
+
+def replace_file_extension(path, ext):
+    tokens = path.split('.')[:-1]
+    return '.'.join(tokens.appends(ext))
+
+
+def append_file_name_suffix(path, suffix):
+    tokens = path.split('.')
+    tokens[-2] += '_' + suffix
+    return '.'.join(tokens)
+
+
+def get_file_directory(path):
+    return os.path.dirname(path)
+
+
+def get_file_directory_name(path):
+    return os.path.basename(get_file_directory(path))
+
+
+def create_directory(path):
+    if not os.path.isdir(path):
+        os.makedirs(path, exist_ok=True)
+
+
+def load_graph_def_from_pb(path):
+    tf.reset_default_graph()
+    graph_def = tf.GraphDef()
+    with open(path, "rb") as f:
+        graph_def.ParseFromString(f.read())
+    return graph_def
+
+
+def save_graph_def(graph_def, path, as_text=False):
+    if as_text:
+        with open(path, "w") as f:
+            f.write(text_format.MessageToString(graph_def))
+    else:
+        with open(path, "wb") as f:
+            f.write(graph_def.SerializeToString())
+
+
+def get_node_name(tensor_name):
+    if tensor_name.startswith("^"):
+        return tensor_name[1:]
+    return tensor_name.split(":")[0]
+
+
+def get_graph_def_io_nodes(graph_def):
+    consumed = set()
+    inputs = []
+    outputs = []
+    for node in graph_def.node:
+        for i in node.input:
+            consumed.add(get_node_name(i))
+        if node.op in ["Placeholder", "PlaceholderWithDefault", "PlaceholderV2"]:
+            inputs.append(node.name)
+
+    for node in graph_def.node:
+        if node.name not in consumed and node.name not in inputs:
+            outputs.append(node.name)
+
+    return inputs, outputs
+
+
+class main(object):
+    @staticmethod
+    def convert_pb_to_pbtxt(input_path, output_path=None):
+        if not output_path:
+            output_path = replace_file_extension(input_path, "pbtxt")
+
+        logging.info("load from %s", input_path)
+        graph_def = load_graph_def_from_pb(input_path)
+
+        logging.info("save to %s", output_path)
+        save_graph_def(graph_def, output_path, as_text=True)
+
+    @staticmethod
+    def convert_pb_to_summary(input_path, output_dir=None, start_tensorboard=False, port=6006):
+        if not output_dir:
+            output_dir = input_path + ".summary"
+
+        logging.info("load from %s", input_path)
+        graph_def = load_graph_def_from_pb(input_path)
+
+        logging.info("save to %s", output_dir)
+        create_directory(output_dir)
+        with tf.Session() as sess:
+            tf.import_graph_def(graph_def, name=get_file_name_without_ext(input_path))
+            train_writer = tf.summary.FileWriter(output_dir)
+            train_writer.add_graph(sess.graph)
+            train_writer.close()
+
+        if start_tensorboard:
+            logging.info("launch tensorboard")
+            os.system("start tensorboard --logdir {} --port {}".format(output_dir, port))
+            os.system("start http://localhost:{}".format(port))
+
+    @staticmethod
+    def get_graph_io_nodes(input_path):
+        logging.info("load from %s", input_path)
+        graph_def = load_graph_def_from_pb(input_path)
+        inputs, outputs = get_graph_def_io_nodes(graph_def)
+        logging.info("graph has:")
+        logging.info("\t%s inputs: %s", len(inputs), ','.join(inputs))
+        logging.info("\t%s (possible) outputs: %s", len(inputs), ','.join(outputs))
+
+    @staticmethod
+    def extract_sub_graph(input_path, output_path=None, dest_nodes=None):
+        if not output_path:
+            output_path = append_file_name_suffix(input_path, "sub")
+
+        logging.info("load from %s", input_path)
+        graph_def = load_graph_def_from_pb(input_path)
+        logging.info("\ttotal node = %s", len(graph_def.node))
+
+        if dest_nodes:
+            dest_nodes = dest_nodes.split(',')
+        else:
+            _, dest_nodes = get_graph_def_io_nodes(graph_def)
+
+        graph_def = graph_util.extract_sub_graph(graph_def, dest_nodes)
+        logging.info("save to %s", output_path)
+        logging.info("\ttotal node = %s", len(graph_def.node))
+        save_graph_def(graph_def, output_path)
+
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser()
+    subparsers = parser.add_subparsers()
+
+    # pb2txt
+    subparser = subparsers.add_parser("pb2txt", help="convert pb to pbtxt")
+    subparser.add_argument("--input", dest="input_path", required=True, help="input pb path")
+    subparser.add_argument("--output", dest="output_path", help="output pbtxt path")
+    subparser.set_defaults(func=main.convert_pb_to_pbtxt)
+
+    # pb2summary
+    subparser = subparsers.add_parser("pb2summary", help="create summary from pb")
+    subparser.add_argument("--input", dest="input_path", required=True, help="input pb path")
+    subparser.add_argument("--output", dest="output_dir", help="output summary directory")
+    subparser.add_argument("--tb", dest="start_tensorboard", action="store_true", default=False,
+                           help="open with tensorboard")
+    subparser.add_argument("--port", type=int, help="tensorboard port")
+    subparser.set_defaults(func=main.convert_pb_to_summary)
+
+    # io
+    subparser = subparsers.add_parser("io", help="get input nodes for graph, guess output nodes")
+    subparser.add_argument("--input", dest="input_path", required=True, help="input pb path")
+    subparser.set_defaults(func=main.get_graph_io_nodes)
+
+    # extract
+    subparser = subparsers.add_parser("extract", help="extract sub-graph")
+    subparser.add_argument("--input", dest="input_path", required=True, help="input pb path")
+    subparser.add_argument("--output", dest="output_path", help="output pb path")
+    subparser.add_argument("--dest_nodes", help="dest nodes")
+    subparser.set_defaults(func=main.extract_sub_graph)
+
+    if len(sys.argv) <= 2:
+        parser.print_help()
+        sys.exit()
+
+    (args, unknown) = parser.parse_known_args()
+
+    func = args.func
+    del args.func
+
+    args = dict(filter(lambda x: x[1], vars(args).items()))
+    func(**args)