Tag: fifo

Python (Twisted) – чтение из fifo и отправка прочитанных данных в несколько протоколов

Я пытаюсь написать какой-то мультипрограммный бот (jabber / irc), который будет читать сообщения из файла fifo (в основном один лайнер), а затем отправлять их на контакты irc канала и jabber. До сих пор мне удалось создать две фабрики для подключения к jabber и irc, и они, похоже, работают. Однако у меня проблема с чтением файла […]

Карта файлов в память

Я объясню, в чем моя проблема, так как важно понять, чего я хочу :-). Я работаю над написанным на пионе конвейером, который использует несколько внешних инструментов для выполнения нескольких анализов данных геномики. Один из этих инструментов работает с очень большими файлами fastq, которые в конце концов не более чем обычные текстовые файлы. Обычно эти файлы […]

OSError: Ресурс временно недоступен. Что вызывает это?

Задний план У меня есть два процесса python, которые должны взаимодействовать друг с другом. Комбинация обрабатывается классом Pipe. Я сделал для этого отдельный класс, потому что большая часть информации, которая должна быть передана, поставляется в виде словарей, поэтому Pipe реализует довольно простой протокол для этого. Вот конструктор трубы: def __init__(self,sPath): """ create the fifo. if […]

Получение readline для блокировки на FIFO

Я создаю fifo: mkfifo tofetch Я запустил этот код python: fetchlistfile = file("tofetch", "r") while 1: nextfetch = fetchlistfile.readline() print nextfetch Он, как я надеюсь, останавливается на readline. Я бегу: echo "test" > tofetch И моя программа больше не останавливается. Он читает строку, а затем продолжает цикл навсегда. Почему он не заглохнет, когда новых данных […]

Как передать информацию демону Python?

У меня есть демон Python, работающий в системе Linux. Я хотел бы передать информацию, такую ​​как «Боб», «Алиса» и т. Д., И иметь демоновую печать «Привет Боб». и "Hello Alice" в файл. Это должно быть асинхронным. Демон Python должен ждать информации и распечатывать его всякий раз, когда он получает что-то. Какой был бы лучший способ […]

Python и FIFO

Я пытался понять FIFO, используя Python под linux, и я обнаружил странное поведение, которого я не понимаю. Ниже представлен fifoserver.py import sys import time def readline(f): s = f.readline() while s == "": time.sleep(0.0001) s = f.readline() return s while True: f = open(sys.argv[1], "r") x = float(readline(f)) g = open(sys.argv[2], "w") g.write(str(x**2) + "\n") […]

Как реализовать очередь FIFO, которая поддерживает пространства имен

Я использую следующий подход для обработки очереди FIFO на основе Google App Engine db.Model ( см. Этот вопрос ). from google.appengine.ext import db from google.appengine.ext import webapp from google.appengine.ext.webapp import run_wsgi_app class QueueItem(db.Model): created = db.DateTimeProperty(required=True, auto_now_add=True) data = db.BlobProperty(required=True) @staticmethod def push(data): """Add a new queue item.""" return QueueItem(data=data).put() @staticmethod def pop(): """Pop the […]

Как читать имя FIFO не блокируемо?

Я создаю FIFO и периодически открываю его в режиме только для чтения и без блокировки из a.py: os.mkfifo(cs_cmd_fifo_file, 0777) io = os.open(fifo, os.O_RDONLY | os.O_NONBLOCK) buffer = os.read(io, BUFFER_SIZE) От b.py откройте fifo для записи: out = open(fifo, 'w') out.write('sth') Тогда a.py вызовет ошибку: buffer = os.read(io, BUFFER_SIZE) OSError: [Errno 11] Resource temporarily unavailable Кто-нибудь […]

Как правильно писать FIFO в Python?

Что-то очень странное происходит, когда я открываю FIFO (именованные каналы) в Python для записи. Посмотрите, что происходит, когда я пытаюсь открыть FIFO для записи в интерактивном интерпретаторе: >>> fifo_write = open('fifo', 'w') Вышеупомянутая строка блокирует до тех пор, пока я не открою другой интерпретатор и не наберу следующее: >>> fifo_read = open('fifo', 'r') >>> fifo.read() […]

Какие условия приводят к тому, что открытый, неблокирующий именованный канал (fifo) является «недоступным» для чтения?

Ситуация: new_pipe = os.open(pipe_path, os.O_RDONLY | os.O_NONBLOCK) # pipe_path points to a FIFO data = os.read(new_pipe, 1024) Чтение иногда вызывает errno -11: ресурс временно недоступен. Когда возникает эта ошибка? Это кажется очень редким, поскольку обычные случаи возвращают данные: Если ни один писатель не открыл трубку, возвращается пустая строка str (''). Если у писателя открыт канал, […]

Interesting Posts for Van-Lav

Является ли threading.local () безопасным способом хранения переменных для одного запроса в Google AppEngine?

Как выполнить многопроцессорную обработку для одной функции в Python?

boost :: python: список Python для std :: vector

Newbie Django: создание проекта с несколькими приложениями или всего в одном

Прочтите заархивированный файл в виде панды DataFrame

Как понять символ равенства «=» в тексте электронной почты IMAP?

Ошибка при вызове eval () в переменной Tensor в keras

Последовательный или параллельный: какой способ читать несколько файлов в python?

Есть ли простой способ получить все разрывы функции в некоторой области с sympy?

Как преобразовать локальное время в UTC в Python?

Многоязычные версии python и интерпретаторы

Сломанная труба во время потока

Получите «бит» для float в Python?

Почему% s быстрее, чем% d для целочисленной замены в python?

изменение версии python, используемой в virtualenv

Python - лучший язык программирования в мире.