tf.data.experimental.service.DispatcherConfig

Класс конфигурации для диспетчеров службы tf.data.

tf.data.experimental.service.DispatcherConfig(
    port=0, protocol='grpc', work_dir=None, fault_tolerant_mode=False,
    job_gc_check_interval_ms=None, job_gc_timeout_ms=None
)

Поля:

• port: Указывает порт для привязки. Значение 0 указывает, что сервер может привязаться к любому доступному порту.
• protocol: Протокол для связи со службой tf.data. По умолчанию "grpc".
• work_dir: Каталог для хранения состояния диспетчера. Этот аргумент необходим для возможности восстановления диспетчера после перезапуска.
• fault_tolerant_mode: Необходимо ли диспетчеру записывать свое состояние в журнал, чтобы он мог восстановиться после перезапуска. Состояние диспетчера, включая зарегистрированные наборы данных и созданные задания, синхронно записывается в журнал перед ответом на запросы RPC. Если True, work_dir также должны быть указаны.
• job_gc_check_interval_ms: Как часто диспетчер должен сканировать, чтобы удалить старые и неиспользуемые задания, в миллисекундах. Если не задано, среда выполнения выберет разумное значение по умолчанию. Более высокое значение уменьшит нагрузку на диспетчера, а более низкое значение уменьшит время, необходимое диспетчеру для сбора мусора устаревших заданий.
• job_gc_timeout_ms: Сколько времени задание должно быть неиспользуемым, прежде чем станет кандидатом для сбора мусора, в миллисекундах. Если не задано, среда выполнения выберет разумное значение по умолчанию. Более высокое значение приведет к тому, что задания будут оставаться дольше без потребителей. Это полезно, если есть большой временной промежуток между чтением потребителей из задания. Более низкое значение уменьшит время, необходимое для освобождения ресурсов от устаревших заданий.