Python для эмуляции удаленного хвоста -f?

Модуль paramiko поддерживает соединение через ssh с python.

http://www.lag.net/paramiko/

В pysftp есть несколько примеров его использования, и метод выполнения команды может быть тем, что вы ищете. Он создаст файл, подобный объекту команды, которую вы выполняете. Я не могу сказать, дает ли он вам живые данные.

http://code.google.com/p/pysftp/

Я знаю, что это не ответ на твои вопросы, но...

Может быть, вы могли бы попробовать использовать screen. Если ваша сессия обрывается, вы всегда можете снова подключиться, и хвост по-прежнему будет работать. Он также поддерживает многопользовательский режим, поэтому 2 пользователя могут просматривать одну и ту же команду tail.

http://en.wikipedia.org/wiki/GNU_Screen

создать с именем «журнал»:

screen -S log

Отключить:

[CTRL]+A D

снова прикрепить

screen -r log

список, когда вы можете вспомнить имя

screen -list

Чтобы избавиться от сеанса, просто введите в нем exit.

Я думаю, что идея с экраном — лучшая идея, но если вы не хотите использовать ssh и хотите, чтобы это сделал скрипт Python. Вот простой pythonic XMLRPC способ получения информации. Он будет обновляться только тогда, когда что-то было добавлено к рассматриваемому файлу.

Это файл клиента. Вы сообщаете, какой файл вы хотите прочитать и на каком компьютере он находится.

#!/usr/bin/python
# This should be run on the computer you want to output the files
# You must pass a filename and a location
# filename must be the full path from the root directory, or relative path
# from the directory the server is running
# location must be in the form of http://location:port (i.e. http:localhost:8000)

import xmlrpclib, time, sys, os

def tail(filename, location):
   # connect to server
   s = xmlrpclib.ServerProxy(location)

   # get starting length of file
   curSeek = s.GetSize(filename)

   # constantly check
   while 1:
      time.sleep(1) # make sure to sleep

      # get a new length of file and check for changes
      prevSeek = curSeek

      # some times it fails if the file is being writter to,
      # we'll wait another second for it to finish
      try:
         curSeek = s.GetSize(filename)
      except:
         pass

      # if file length has changed print it
      if prevSeek != curSeek:
         print s.tail(filename, prevSeek),


def main():
   # check that we got a file passed to us
   if len(sys.argv) != 3 or not os.path.isfile(sys.argv[1]):
      print 'Must give a valid filename.'
      return

   # run tail function
   tail(sys.argv[1], sys.argv[2])

main()

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

#!/usr/bin/python
# This runs on the computer(s) you want to read the file from
# Make sure to change out the HOST and PORT variables
HOST = 'localhost'
PORT = 8000

from SimpleXMLRPCServer import SimpleXMLRPCServer
from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler

import time, os

def GetSize(filename):
   # get file size
   return os.stat(filename)[6]

def tail(filename, seek):
   #Set the filename and open the file
   f = open(filename,'r')

   #Find the size of the file and move to the end
   f.seek(seek)
   return f.read()

def CreateServer():
   # Create server
   server = SimpleXMLRPCServer((HOST, PORT),
                               requestHandler=SimpleXMLRPCRequestHandler)

# register functions
   server.register_function(tail, 'tail')
   server.register_function(GetSize, 'GetSize')

   # Run the server's main loop
   server.serve_forever()

# start server
CreateServer()

В идеале вы запускаете сервер один раз, а затем с клиента запускаете «python client.py sample.log http://somehost:8000. "и это должно начаться. Надеюсь, это поможет.

Я разместил вопрос о чем-то подобном с кодом (paramiko)

tail -f через ssh с Paramiko имеет увеличивающаяся задержка

Я написал функцию, которая делает это:

import paramiko
import time
import json

DEFAULT_MACHINE_USERNAME="USERNAME"
DEFAULT_KEY_PATH="DEFAULT_KEY_PATH"

def ssh_connect(machine, username=DEFAULT_MACHINE_USERNAME,
                key_filename=DEFAULT_KEY_PATH):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(hostname=machine, username=username, key_filename=key_filename)
    return ssh

def tail_remote_file(hostname, filepath, key_path=DEFAULT_KEY_PATH,
                     close_env_variable="CLOSE_TAIL_F", env_file='~/.profile'):
    ssh = ssh_connect(hostname, key_filename=key_path)

    def set_env_variable(to_value):
        to_value_str = "true" if to_value else "false"
        from_value_str = "false" if to_value else "true"
        ssh.exec_command('sed -i \'s/export %s=%s/export %s=%s/g\' %s' %
                         (close_env_variable, from_value_str,
                          close_env_variable, to_value_str, env_file))
        time.sleep(1)

    def get_env_variable():
        command = "source .profile; echo $%s" % close_env_variable
        stdin, stdout_i, stderr = ssh.exec_command(command)
        print(command)
        out = stdout_i.read().replace('\n', '')
        return out

    def get_last_line_number(lines_i, line_num):
        return int(lines_i[-1].split('\t')[0]) + 1 if lines_i else line_num

    def execute_command(line_num):
        command = "cat -n %s | tail --lines=+%d" % (filepath, line_num)
        stdin, stdout_i, stderr = ssh.exec_command(command)
        stderr = stderr.read()
        if stderr:
            print(stderr)
        return stdout_i.readlines()

    stdout = get_env_variable()
    if not stdout:
        ssh.exec_command("echo 'export %s=false' >> %s" %
                         (close_env_variable, env_file))
    else:
        ssh.exec_command(
            'sed -i \'s/export %s=true/export %s=false/g\' %s' %
            (close_env_variable, close_env_variable, env_file))
    set_env_variable(False)

    lines = execute_command(0)
    last_line_num = get_last_line_number(lines, 0)

    while not json.loads(get_env_variable()):
        for l in lines:
            print('\t'.join(t.replace('\n', '') for t in l.split('\t')[1:]))
        last_line_num = get_last_line_number(lines, last_line_num)
        lines = execute_command(last_line_num)
        time.sleep(1)

    ssh.close()

Я написал библиотеку, которая позволяет вам делать именно это — ознакомьтесь с «удаленной» функцией PimpedSubprocess (на github) или PimpedSubprocess (на PyPI)