tf.compat.v1.train.SingularMonitoredSession
Объект, похожий на сессию, который обрабатывает инициализацию, восстановление и хуки.
tf.compat.v1.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>Stringrepresentation 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/r2.4/api_docs/python/tf/compat/v1/train/SingularMonitoredSession