11

这与我之前的问题有关，但有所不同。

我有以下fabfile：

from fabric.api import *

host1 = '192.168.200.181'
offline_host2 = '192.168.200.199'
host3 = '192.168.200.183'

env.hosts = [host1, offline_host2, host3]
env.warn_only = True

def df_h():
    with settings(warn_only=True):
        run("df -h | grep sda3")

输出是：

[192.168.200.199] run: df -h | grep sda3

Fatal error: Low level socket error connecting to host 192.168.200.199: No route to host

Aborting.

在执行命中离线服务器后，它会立即中止，而不管 env.hosts 列表中的其他服务器。

我使用了环境设置“warn_only=True”，但也许我使用不当。

如何修改此行为，使其仅打印错误并继续执行？

4

4 回答 4

21

从 1.4 版开始，Fabric 有一个--skip-bad-hosts可以从命令行设置的选项，也可以通过在你的 fab 文件中设置变量来设置。

env.skip_bad_hosts = True

该选项的文档在这里： http ://docs.fabfile.org/en/latest/usage/fab.html#cmdoption--skip-bad-hosts

不要忘记也显式设置超时值。

于 2014-04-17T16:54:10.317 回答
15

根据有关 warn_only 的 Fabric 文档，

env.warn_onlyrun"指定当//遇到错误条件时是否发出警告，而不是中止sudo。local

这在服务器关闭的情况下无济于事，因为失败发生在执行run/ sudo/之前的 SSH 尝试期间local。

一种解决方案是创建一个函数以在执行任务之前检查每个服务器是否已启动。下面是我使用的代码。

from __future__ import print_function
from fabric.api import run, sudo, local, env
import paramiko
import socket

host1 = '192.168.200.181'
offline_host2 = '192.168.200.199'
host3 = '192.168.200.183'

env.hosts = [host1, offline_host2, host3]

def df_h():
    if _is_host_up(env.host, int(env.port)) is True:
        run("df -h | grep sda1")


def _is_host_up(host, port):
    # Set the timeout
    original_timeout = socket.getdefaulttimeout()
    new_timeout = 3
    socket.setdefaulttimeout(new_timeout)
    host_status = False
    try:
        transport = paramiko.Transport((host, port))
        host_status = True
    except:
        print('***Warning*** Host {host} on port {port} is down.'.format(
            host=host, port=port)
        )
    socket.setdefaulttimeout(original_timeout)
    return host_status
于 2010-04-01T15:53:25.750 回答
1

你没有使用不当。您甚至可以只--warn-only=true在命令行上提供。 这是开发团队建议的记录方法。

于 2009-12-24T05:15:54.183 回答
1

根据马修的回答，我想出了一个装饰器，它可以做到这一点：

from __future__ import with_statement
from paramiko import Transport
from socket import getdefaulttimeout, setdefaulttimeout
from fabric.api import run, cd, env, roles


roledefs = {
    'greece': [
        'alpha',
        'beta'
    ],
    'arabia': [
        'kha',
        'saad'
    ]
}

env.roledefs = roledefs


def if_host_offline_ignore(fn):
    def wrapped():
        original_timeout = getdefaulttimeout()
        setdefaulttimeout(3)
        try:
            Transport((env.host, int(env.port)))
            return fn()
        except:
            print "The following host appears to be offline: " + env.host
        setdefaulttimeout(original_timeout)
    return wrapped


@roles('greece')
@if_host_offline_ignore
def hello_greece():
    with cd("/tmp"):
        run("touch hello_greece")


@roles('arabia')
@if_host_offline_ignore
def hello_arabia():
    with cd("/tmp"):
        run("touch hello_arabia")

当您有多个主机和角色时，它特别有用。

于 2012-10-04T12:54:54.380 回答