Spec-Zone.ru › TensorFlow

tf.distribute.cluster_resolver.SimpleClusterResolver

Простая реализация ClusterResolver, принимающая все атрибуты.

Наследует: ClusterResolver

Альтернативные имена

Псевдонимы совместимости для миграции

Подробнее см. в руководстве по миграции.

tf.compat.v1.distribute.cluster_resolver.SimpleClusterResolver

tf.distribute.cluster_resolver.SimpleClusterResolver(
    cluster_spec,
    master='',
    task_type=None,
    task_id=None,
    environment='',
    num_accelerators=None,
    rpc_layer=None
)

Используется в блокнотах

Используется в руководствах
  • Обучение с сервером параметров и ParameterServerStrategy

Описание аргументов конструктора см. в документации базового класса.

Этот класс удобен, если нужно указать некоторые или все атрибуты.

Пример использования с tf.distribute.Strategy:

cluster = tf.train.ClusterSpec({"worker": ["worker0.example.com:2222",
                                           "worker1.example.com:2222"]})

# On worker 0
cluster_resolver = SimpleClusterResolver(cluster, task_type="worker",
                                         task_id=0,
                                         num_accelerators={"GPU": 8},
                                         rpc_layer="grpc")
strategy = tf.distribute.experimental.MultiWorkerMirroredStrategy(
    cluster_resolver=cluster_resolver)

# On worker 1
cluster_resolver = SimpleClusterResolver(cluster, task_type="worker",
                                         task_id=1,
                                         num_accelerators={"GPU": 8},
                                         rpc_layer="grpc")
strategy = tf.distribute.experimental.MultiWorkerMirroredStrategy(
    cluster_resolver=cluster_resolver)
Атрибуты
environment Возвращает текущую среду, в которой выполняется TensorFlow.

Возможны два возвращаемых значения: "google" (если TensorFlow выполняется во внутренней среде Google) или пустая строка (если TensorFlow выполняется в другом месте).

Если вы реализуете ClusterResolver, работающий как в среде Google, так и в мире открытого исходного кода (например, TPU ClusterResolver или аналогичный), вам потребуется возвращать соответствующую строку в зависимости от среды, которую нужно определить.

Если же вы реализуете ClusterResolver, предназначенный только для TensorFlow с открытым исходным кодом, реализовывать это свойство не нужно.

rpc_layer
task_id Возвращает идентификатор задачи, который указывает этот ClusterResolver.

В распределенной среде TensorFlow для каждого задания может быть задан идентификатор задачи — индекс экземпляра в пределах его типа задачи. Это полезно, когда пользователю нужно выполнять определенный код в зависимости от индекса задачи. Например:

cluster_spec = tf.train.ClusterSpec({
    "ps": ["localhost:2222", "localhost:2223"],
    "worker": ["localhost:2224", "localhost:2225", "localhost:2226"]
})

# SimpleClusterResolver is used here for illustration; other cluster
# resolvers may be used for other source of task type/id.
simple_resolver = SimpleClusterResolver(cluster_spec, task_type="worker",
                                        task_id=0)

...

if cluster_resolver.task_type == 'worker' and cluster_resolver.task_id == 0:
  # Perform something that's only applicable on 'worker' type, id 0. This
  # block will run on this particular instance since we've specified this
  # task to be a 'worker', id 0 in above cluster resolver.
else:
  # Perform something that's only applicable on other ids. This block will
  # not run on this particular instance.

Возвращает None, если эта информация недоступна или неприменима в текущей распределенной среде, например при обучении с помощью tf.distribute.cluster_resolver.TPUClusterResolver.

Дополнительные сведения см. в документации класса tf.distribute.cluster_resolver.ClusterResolver.

task_type Возвращает тип задачи, который указывает этот ClusterResolver.

В распределенной среде TensorFlow для каждого задания может быть задан тип задачи. Допустимые типы задач в TensorFlow: 'chief' — рабочий узел с дополнительными обязанностями, 'worker' — обычный рабочий узел для обучения или оценки, 'ps' — сервер параметров и 'evaluator' — узел оценки, который проверяет контрольные точки по метрикам.

Подробнее о типах задач 'chief' и 'worker', которые используются чаще всего, см. в разделе Конфигурация для нескольких рабочих узлов.

Доступ к этой информации полезен, когда пользователю нужно выполнять определенный код в зависимости от типа задачи. Например:

cluster_spec = tf.train.ClusterSpec({
    "ps": ["localhost:2222", "localhost:2223"],
    "worker": ["localhost:2224", "localhost:2225", "localhost:2226"]
})

# SimpleClusterResolver is used here for illustration; other cluster
# resolvers may be used for other source of task type/id.
simple_resolver = SimpleClusterResolver(cluster_spec, task_type="worker",
                                        task_id=1)

...

if cluster_resolver.task_type == 'worker':
  # Perform something that's only applicable on workers. This block
  # will run on this particular instance since we've specified this task to
  # be a worker in above cluster resolver.
elif cluster_resolver.task_type == 'ps':
  # Perform something that's only applicable on parameter servers. This
  # block will not run on this particular instance.

Возвращает None, если эта информация недоступна или неприменима в текущей распределенной среде, например при обучении с помощью tf.distribute.experimental.TPUStrategy.

Дополнительные сведения см. в документации класса tf.distribute.cluster_resolver.ClusterResolver.

Методы

cluster_spec

Просмотреть исходный код

cluster_spec()

Возвращает ClusterSpec, переданный конструктору.

master

Просмотреть исходный код

master(
    task_type=None, task_id=None, rpc_layer=None
)

Возвращает адрес главного узла, используемый при создании сеанса.

Примечание: это полезно только для TensorFlow 1.x.
Аргументы
task_type (Необязательно) Тип задачи TensorFlow главного узла.
task_id (Необязательно) Индекс задачи TensorFlow главного узла.
rpc_layer (Необязательно) RPC, используемый распределенным TensorFlow.
Возвращает
Имя или URL главного узла сеанса.

Если указаны task_type и task_id, они переопределят строку master, переданную функции инициализации.

num_accelerators

Просмотреть исходный код

num_accelerators(
    task_type=None, task_id=None, config_proto=None
)

Возвращает количество ядер ускорителей на рабочем узле.

SimpleClusterResolver не обнаруживает ускорители автоматически, поэтому все аргументы не используются, а возвращается значение, переданное конструктору.

Аргументы
task_type Не используется.
task_id Не используется.
config_proto Не используется.

© 2022 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 4.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/api_docs/python/tf/distribute/cluster_resolver/SimpleClusterResolver

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API