tf.distribute.cluster_resolver.SimpleClusterResolver
Простая реализация ClusterResolver, принимающая все атрибуты.
Наследует: ClusterResolver
tf.distribute.cluster_resolver.SimpleClusterResolver(
cluster_spec,
master='',
task_type=None,
task_id=None,
environment='',
num_accelerators=None,
rpc_layer=None
)
Используется в блокнотах
| Используется в руководствах |
|---|
Описание аргументов конструктора см. в документации базового класса.
Этот класс удобен, если нужно указать некоторые или все атрибуты.
Пример использования с 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.
Возвращает Дополнительные сведения см. в документации класса |
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.
Возвращает Дополнительные сведения см. в документации класса |
Методы
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