Тензор потока: интегрировать модель Кераса в оценщик model_fn - PullRequest
0 голосов
/ 08 февраля 2019

Я работаю над проблемой , используя предварительно подготовленную модель keras.applications в model_fn оценщика.

В моей исследовательской группе мы используем оценщик Tensorflow, поскольку они предлагают многопреимущества через параллельное обучение и оценку, теплый старт обучения, простое обслуживание и т. д. Таким образом, Мне нужно решение, которое можно использовать в model_fn оценщика.

В принципе, я хочуЯ использую предварительно обученный граф в моем model_fn, и я мог использовать для этого модели из keras.applications.К сожалению, до сих пор я не смог подключить модель keras.applications к model_fn подходящим способом.

Я хочу использовать визуальный экстрактор без верхних слоев (resnet50, mobilenet, nasnet ...), чтобыИзвлечение векторов объектов, а позже я могу захотеть откорректировать это извлечение.Это исключило бы использование визуального экстрактора в качестве шага предварительной обработки вне model_fn.

После долгих попыток с моим реальным набором данных я вернулся к старому доброму MNIST и придумал минимальный пример, чтобы указать, что я ищуза.Я посмотрел здесь на stackoverflow и следовал этому объяснению изначально.

В приведенном ниже примере я пытаюсь классифицировать набор данных MNIST с архитектурой mobilenet как визуальный экстрактор.Есть два примера передачи функций и один пример вообще не использования модели keras.Код очень близок к официальному примеру TF custom_estimator.Только набор данных сокращается, чтобы легко помещаться в память, а изображения масштабируются и преобразуются в rgb для соответствия структуре сети.

Примеры 1 и 2 приводят к застойным потерям обучения и постоянной потере воценка. Третий случай показывает, что без модели потери действительно уменьшаются (хотя общая производительность плохая, как можно ожидать). В этом примере я не снимаю для высокой производительности!Я просто пытаюсь показать, где я застрял, и надеюсь, что кто-то может помочь.

Идеи и дальнейшие мысли:

  • Тот факт, что потеря оценки постоянна, может означать, что модельне проходит на входе вообще.Однако как я мог это проверить?В этой смешанной ситуации tf / keras мне не удалось заставить tf.historgram работать для отображения активаций или весов.
  • Еще один post указывает, что keras держит один сеанс в фоновом режиме.Хотя API оценки формирует два графика для обучения и оценки, в фоновом режиме это может привести к путанице.
  • Если есть способ использовать график с его весами, мне не нуженOO-интерфейс модели keras, но как это может работать?
  • Установка фазы обучения в бэкэнде keras также создает потери в потере также для случая без использования функций модели, что указывает на проблему двух сессийтаким образом, это закомментировано ниже.

Я также открыл выпуск на github, так как мне кажется, что эта функциональность должна работать.

Ниже,Вы можете найти автономный пример.Это должно закончиться из коробки после просто скопировать / вставить это.Любая помощь высоко ценится!


        import tensorflow as tf
        import numpy as np

        from keras.datasets import mnist


        # switch to example 1/2/3
        EXAMPLE_CASE = 3

        # flag for initial weights loading of keras model
        _W_INIT = True


        def dense_net(features, labels, mode, params):
            # --- code to load a keras application ---

            # commenting in this line leads to a bump in the loss everytime the
            # evaluation is run, this indicating that keras does not handle well the
            # two sessions of the estimator API
            # tf.keras.backend.set_learning_phase(mode == tf.estimator.ModeKeys.TRAIN)
            global _W_INIT

            model = tf.keras.applications.MobileNet(
                input_tensor=features,
                input_shape=(128, 128, 3),
                include_top=False,
                pooling='avg',
                weights='imagenet' if _W_INIT else None)

            # only initialize weights once
            if _W_INIT:
                _W_INIT = False

            # switch cases
            if EXAMPLE_CASE == 1:
                # model.output is the same as model.layers[-1].output
                img = model.layers[-1].output
            elif EXAMPLE_CASE == 2:
                img = model(features)
            elif EXAMPLE_CASE == 3:
                # do not use keras features
                img = tf.keras.layers.Flatten()(features)
            else:
                raise NotImplementedError

            # --- regular code from here on ---
            for units in params['dense_layers']:
                img = tf.keras.layers.Dense(units=units, activation='relu')(img)

            logits = tf.keras.layers.Dense(units=10,
                                           activation='relu')(img)

            # compute predictions
            probs = tf.nn.softmax(logits)
            predicted_classes = tf.argmax(probs, 1)

            # compute loss
            loss = tf.losses.sparse_softmax_cross_entropy(labels, logits)

            acc = tf.metrics.accuracy(labels, predicted_classes)
            metrics = {'accuracy': acc}
            tf.summary.scalar('accuarcy', acc[1])

            if mode == tf.estimator.ModeKeys.EVAL:
                return tf.estimator.EstimatorSpec(
                    mode, loss=loss, eval_metric_ops=metrics)

            # create training operation
            assert mode == tf.estimator.ModeKeys.TRAIN

            optimizer = tf.train.AdagradOptimizer(learning_rate=0.01)
            train_op = optimizer.minimize(loss, global_step=tf.train.get_global_step())
            return tf.estimator.EstimatorSpec(mode, loss=loss, train_op=train_op)


        def prepare_dataset(in_tuple, n):
            feats = in_tuple[0][:n, :, :]
            labels = in_tuple[1][:n]
            feats = feats.astype(np.float32)
            feats /= 255
            labels = labels.astype(np.int32)
            return (feats, labels)


        def _parse_func(features, labels):
            feats = tf.expand_dims(features, -1)
            feats = tf.image.grayscale_to_rgb(feats)
            feats = tf.image.resize_images(feats, (128, 128))
            return (feats, labels)


        def load_mnist(n_train=10000, n_test=3000):
            train, test = mnist.load_data()
            train = prepare_dataset(train, n_train)
            test = prepare_dataset(test, n_test)
            return train, test


        def train_input_fn(imgs, labels, batch_size):
            dataset = tf.data.Dataset.from_tensor_slices((imgs, labels))
            dataset = dataset.map(_parse_func)
            dataset = dataset.shuffle(500)
            dataset = dataset.repeat().batch(batch_size)
            return dataset


        def eval_input_fn(imgs, labels, batch_size):
            dataset = tf.data.Dataset.from_tensor_slices((imgs, labels))
            dataset = dataset.map(_parse_func)
            dataset = dataset.batch(batch_size)
            return dataset


        def main(m_dir=None):
            # fetch data
            (x_train, y_train), (x_test, y_test) = load_mnist()

            train_spec = tf.estimator.TrainSpec(
                input_fn=lambda: train_input_fn(
                    x_train, y_train, 30),
                max_steps=150)

            eval_spec = tf.estimator.EvalSpec(
                input_fn=lambda: eval_input_fn(
                    x_test, y_test, 30),
                steps=100,
                start_delay_secs=0,
                throttle_secs=0)

            run_cfg = tf.estimator.RunConfig(
                model_dir=m_dir,
                tf_random_seed=2,
                save_summary_steps=2,
                save_checkpoints_steps=10,
                keep_checkpoint_max=1)

            # build network
            classifier = tf.estimator.Estimator(
                model_fn=dense_net,
                params={
                    'dense_layers': [256]},
                config=run_cfg)

            # fit the model
            tf.estimator.train_and_evaluate(
                classifier,
                train_spec,
                eval_spec)


        if __name__ == "__main__":
            main()
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...