tf.train.SingularMonitoredSession
Объект, подобный сеансу, который обрабатывает инициализацию, восстановление и хуки.
tf.train.SingularMonitoredSession(
hooks=None, scaffold=None, master='', config=None, checkpoint_dir=None,
stop_grace_period_secs=120, checkpoint_filename_with_path=None
)
Обратите внимание, что это утилита не рекомендуется для распределённых сред. Для распределённых сред используйте tf.compat.v1.train.MonitoredSession. Различия между MonitoredSession и SingularMonitoredSession следующие:
-
MonitoredSessionобрабатываетAbortedErrorиUnavailableErrorдля распределённых сред, ноSingularMonitoredSessionэтого не делает. -
MonitoredSessionможет быть создан в режимахchiefилиworker.SingularMonitoredSessionвсегда создаётся какchief. - Вы можете получить доступ к объекту сеанса
tf.compat.v1.Session, используемомуSingularMonitoredSession, в то время как в MonitoredSession исходный сеанс является закрытым. Это может быть использовано:- Для
runбез хуков. - Для сохранения и восстановления.
- Для
- Все остальные функции идентичны.
Пример использования:
saver_hook = CheckpointSaverHook(...)
summary_hook = SummarySaverHook(...)
with SingularMonitoredSession(hooks=[saver_hook, summary_hook]) as sess:
while not sess.should_stop():
sess.run(train_op)
Инициализация: В момент создания сеанс с хуками выполняет следующие действия в указанном порядке:
- вызывает
hook.begin()для каждого указанного хука - завершает граф с помощью
scaffold.finalize() - создаёт сеанс
- инициализирует модель с помощью операций инициализации, предоставленных
Scaffold - восстанавливает переменные, если существует контрольная точка
- запускает исполнители очереди
Выполнение: При вызове run() сеанс с хуками выполняет следующие действия:
- вызывает
hook.before_run() - вызывает TensorFlow
session.run()с объединёнными значениями и feed_dict - вызывает
hook.after_run() - возвращает результат
session.run()запрошенного пользователем
Закрытие: В момент close(), сеанс с хуками выполняет следующие действия в порядке:
- вызывает
hook.end() - закрывает исполнители очереди и сеанс
- подавляет ошибку
OutOfRange, которая указывает, что все входные данные обработаны, еслиSingularMonitoredSessionиспользуется в качестве контекста.
| Аргументы | ||
|---|---|---|
hooks | Итерируемый объект SessionRunHook' objects. </td> </tr><tr> <td>scaffold</td> <td> AScaffoldused for gathering or building supportive ops. If not specified a default one is created. It's used to finalize the graph. </td> </tr><tr> <td>master</td> <td>Строкаrepresentation of the TensorFlow master to use. </td> </tr><tr> <td>config</td> <td>ConfigProtoproto used to configure the session. </td> </tr><tr> <td>checkpoint_dir</td> <td> A string. Optional path to a directory where to restore variables. </td> </tr><tr> <td>stop_grace_period_secs</td> <td> Number of seconds given to threads to stop afterclose()has been called. </td> </tr><tr> <td>checkpoint_filename_with_path` | Строка. Необязательный путь к файлу контрольной точки, из которого нужно восстановить переменные. |
| Атрибуты | |
|---|---|
graph | Граф, который был запущен в этом сеансе. |
Подклассы
Методы
close
close()
raw_session
raw_session()
Возвращает базовый объект TensorFlow.Session.
run
run(
fetches, feed_dict=None, options=None, run_metadata=None
)
Выполнение операций в контролируемом сеансе.
Этот метод полностью совместим с методом tf.Session.run().
| Аргументы | |
|---|---|
fetches | Аналогично tf.Session.run(). |
feed_dict | Аналогично tf.Session.run(). |
options | Аналогично tf.Session.run(). |
run_metadata | Аналогично tf.Session.run(). |
| Возвращаемые значения | |
|---|---|
Аналогично tf.Session.run(). |
run_step_fn
run_step_fn(
step_fn
)
Выполнение операций с помощью функции шага.
| Аргументы | |
|---|---|
step_fn | Функция или метод с единственным аргументом типа StepContext. Функция может использовать методы аргумента для выполнения вычислений с доступом к исходному сеансу. Возвращаемое значение step_fn будет возвращено run_step_fn, если не будет запрошен останов. В противном случае следующий вызов should_stop вернёт True. Пример использования: with tf.Graph().as_default():
c = tf.compat.v1.placeholder(dtypes.float32)
v = tf.add(c, 4.0)
w = tf.add(c, 0.5)
def step_fn(step_context):
a = step_context.session.run(fetches=v, feed_dict={c: 0.5})
if a <= 4.5:
step_context.request_stop()
return step_context.run_with_hooks(fetches=w,
feed_dict={c: 0.1})
with tf.MonitoredSession() as session:
while not session.should_stop():
a = session.run_step_fn(step_fn)
Хуки взаимодействуют с вызовом |
| Возвращаемые значения | |
|---|---|
Возвращает возвращаемое значение step_fn. |
| Исключения | |
|---|---|
StopIteration | если step_fn вызвал request_stop(). Может быть перехвачен with tf.MonitoredSession() для закрытия сеанса. |
ValueError | если step_fn не имеет единственного аргумента с именем step_context. Также может иметь необязательный аргумент self для случаев, когда он принадлежит объекту. |
should_stop
should_stop()
__enter__
__enter__()
__exit__
__exit__(
exception_type, exception_value, traceback
)
© 2020 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 3.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/versions/r1.15/api_docs/python/tf/train/SingularMonitoredSession