LXF81:Python - История изменений

AndrewDjVu: /* logclient2.py */

2009-02-03T19:29:26Z

logclient2.py

← Предыдущая		Версия 19:29, 3 февраля 2009
Строка 385:		Строка 385:
	#!/usr/bin/python		#!/usr/bin/python
	# -- coding: utf-8 --		# -- coding: utf-8 --
		+
	import os		import os
	from logclient import LogClient		from logclient import LogClient
		+
	for i in xrange(25):		for i in xrange(25):
-	pid = os.fork()	+	pid = os.fork()
-	if pid == 0:	+	if pid == 0:
-	client = LogClient(sender='client%d' % i, testmode=1)	+	client = LogClient(sender='client%d' % i, testmode=1)
-	client.writelog('Test from client%d' % i)	+	client.writelog('Test from client%d' % i)
-	os._exit(0)	+	os._exit(0)
-	else:	+	else:
-	print 'Start child[%d]' % pid	+	print 'Start child[%d]' % pid
	</source>		</source>

AndrewDjVu: /* logclient.py */

2009-02-03T19:23:26Z

logclient.py

← Предыдущая		Версия 19:23, 3 февраля 2009
Строка 346:		Строка 346:
	#!/usr/bin/python		#!/usr/bin/python
	# -- coding: utf-8 --		# -- coding: utf-8 --
		+
	import sys, socket, time		import sys, socket, time
		+
	class LogClient:		class LogClient:
-	def __init__(self, sender='generic client',	+	def __init__(self, sender='generic client',
-	sockfile='./lserv.sock',	+	sockfile='./lserv.sock',
-	buffersize=1024,	+	buffersize=1024,
-	testmode=0):	+	testmode=0):
-	self.sender = sender	+	self.sender = sender
-	self.sockfile = sockfile	+	self.sockfile = sockfile
-	self.buffersize = buffersize	+	self.buffersize = buffersize
-	self.testmode = testmode	+	self.testmode = testmode
-	def writelog(self, message):	+
-	if self.testmode:	+	def writelog(self, message):
-	time.sleep(5)	+	if self.testmode:
-	self.socket = socket.socket(socket.AF_UNIX)	+	time.sleep(5)
-	self.socket.connect(self.sockfile)	+	self.socket = socket.socket(socket.AF_UNIX)
-	self.socket.send(self.sender)	+	self.socket.connect(self.sockfile)
-	if self.socket.recv(self.buffersize) == 'Sender OK':	+	self.socket.send(self.sender)
-	if self.testmode:	+	if self.socket.recv(self.buffersize) == 'Sender OK':
-	time.sleep(5)	+	if self.testmode:
-	self.socket.send(message)	+	time.sleep(5)
-	if not self.socket.recv(self.buffersize) == 'Message OK':	+	self.socket.send(message)
-	print 'Ошибка: нет подтверждения Message'	+	if not self.socket.recv(self.buffersize) == 'Message OK':
-	else:	+	print 'Ошибка: нет подтверждения Message'
-	print 'Ошибка: нет подтверждения Sender'	+	else:
-	self.socket.close()	+	print 'Ошибка: нет подтверждения Sender'
		+	self.socket.close()
		+
	if __name__ == '__main__':		if __name__ == '__main__':
-	sendername = sys.argv[1]	+	sendername = sys.argv[1]
-	client = LogClient(sender=sendername, testmode=1)	+	client = LogClient(sender=sendername, testmode=1)
-	client.writelog('Test message')	+	client.writelog('Test message')
	</source>		</source>

AndrewDjVu: /* logserver.py */

2009-02-03T19:18:43Z

logserver.py

← Предыдущая		Версия 19:18, 3 февраля 2009
Строка 324:		Строка 324:
	sender = sock.recv(1024)		sender = sock.recv(1024)
	sock.send('Sender OK')		sock.send('Sender OK')
-	senders['sock'] = sender	+	senders[`sock`] = sender
	else:		else:
	message = sock.recv(1024)		message = sock.recv(1024)
	sock.send('Message OK')		sock.send('Message OK')
-	self.writelog('[%s] %s' % (senders['sock'], message))	+	self.writelog('[%s] %s' % (senders[`sock`], message))
	rsocks.remove(sock)		rsocks.remove(sock)
-	del senders['sock']	+	del senders[`sock`]

	def stop(self, signum, frame):		def stop(self, signum, frame):

Mim: /* Сокеты */

2008-12-10T11:43:24Z

Сокеты

← Предыдущая		Версия 11:43, 10 декабря 2008
Строка 51:		Строка 51:
	s.bind('/tmp/test.sock') # привязываем его к файлу		s.bind('/tmp/test.sock') # привязываем его к файлу
	s.listen(1) # начинаем прослушивать		s.listen(1) # начинаем прослушивать
-	conn = s.accept() # ждём подключения	+	conn, addr = s.accept() # ждём подключения
	conn.send('HELO') # дождавшись, отправляем клиенту строку		conn.send('HELO') # дождавшись, отправляем клиенту строку
	data = conn.recv(1024) # получаем от клиента данные		data = conn.recv(1024) # получаем от клиента данные
Строка 77:		Строка 77:
	приняв данные, завершает свою работу. Для постоянной работы фрагмент, начиная с метода accept(), нужно		приняв данные, завершает свою работу. Для постоянной работы фрагмент, начиная с метода accept(), нужно
	поместить в бесконечный цикл (см. пример ниже).		поместить в бесконечный цикл (см. пример ниже).
		+
	===Модуль select===		===Модуль select===
	В Python доступен ещё один способ повысить эффективность работы за счёт параллельного выполнения некоторых операций – модуль select. Он использует системный вызов select для мультиплексирования соединений клиентов в одном цикле событий – метод select этого модуля позволяет отслеживать одновременно		В Python доступен ещё один способ повысить эффективность работы за счёт параллельного выполнения некоторых операций – модуль select. Он использует системный вызов select для мультиплексирования соединений клиентов в одном цикле событий – метод select этого модуля позволяет отслеживать одновременно

Yaleks: /* БЛОКИРОВАТЬ НЕОБЯЗАТЕЛЬНО */

2008-11-20T18:20:37Z

БЛОКИРОВАТЬ НЕОБЯЗАТЕЛЬНО

← Предыдущая		Версия 18:20, 20 ноября 2008
Строка 261:		Строка 261:
	кортеж вида ('''35''', ‘Resource temporarily unavailable’), где первый элемент – числовой код ошибки, а второй –		кортеж вида ('''35''', ‘Resource temporarily unavailable’), где первый элемент – числовой код ошибки, а второй –
	текстовая строка-пояснение. При отсутствии данных генерируется ошибка '''35''', которую мы и игнорируем (''pass''). Здесь		текстовая строка-пояснение. При отсутствии данных генерируется ошибка '''35''', которую мы и игнорируем (''pass''). Здесь
-	мы получаем то же ожидание данных, но уже реализованное самим кодом [[Python]]. Но преимущество здесь в том, что	+	мы получаем то же ожидание данных, но уже реализованное самим кодом Python. Но преимущество здесь в том, что
	вместо оператора ''pass'' можно реализовать любую обработку. Например, переходить к опросу другого сокета.		вместо оператора ''pass'' можно реализовать любую обработку. Например, переходить к опросу другого сокета.

Mim: подправаил отступы, сделал выделение кода и чисел в тексте

2008-11-20T00:10:33Z

подправаил отступы, сделал выделение кода и чисел в тексте

← Предыдущая		Версия 00:10, 20 ноября 2008
Строка 236:		Строка 236:

	=== БЛОКИРОВАТЬ НЕОБЯЗАТЕЛЬНО ===		=== БЛОКИРОВАТЬ НЕОБЯЗАТЕЛЬНО ===
-	Модуль socket также предоставляет возможность работы с неблокирующими вызовами accept(), send() и recv(). Для	+	Модуль '''socket''' также предоставляет возможность работы с неблокирующими вызовами ''accept()'', ''send()'' и ''recv()''. Для
	этого следует предварительно установить значение соответствующего атрибута объекта-сокета с помощью следующего		этого следует предварительно установить значение соответствующего атрибута объекта-сокета с помощью следующего
	метода:		метода:
-	socket.setblocking(0)	+	<source lang="python">
		+	socket.setblocking(0)
		+	</source>

-	Значение 0 переключает сокет в неблокирующий режим работы (по умолчанию используется блокирующий –	+	Значение '''0''' переключает сокет в неблокирующий режим работы (по умолчанию используется блокирующий –
-	значение 1). При этом методы accept(), send() и recv() при отсутствии данных для обработки не останавливают	+	значение '''1'''). При этом методы ''accept()'', ''send()'' и ''recv()'' при отсутствии данных для обработки не останавливают
-	выполнение программы до их появления, а генерируют исключение socket.error. Что с ним делать дальше – решать	+	выполнение программы до их появления, а генерируют исключение ''socket.error''. Что с ним делать дальше – решать
	вам. Например, можно просто игнорировать:		вам. Например, можно просто игнорировать:
	<source lang="python">		<source lang="python">
	while(1):		while(1):
-	try:	+	try:
-	data = sock.recv()	+	data = sock.recv()
-	except socket.error, errcode:	+	except socket.error, errcode:
-	if errcode[0] == 35:	+	if errcode[0] == 35:
-	pass	+	pass
-	else:	+	else:
-	raise(socket.error)	+	raise(socket.error)
	</source>		</source>

-	Второй параметр оператора except – переменная, в которую будет занесён код ошибки. Этот код представляет собой	+	Второй параметр оператора ''except'' – переменная, в которую будет занесён код ошибки. Этот код представляет собой
-	кортеж вида (35, ‘Resource temporarily unavailable’), где первый элемент – числовой код ошибки, а второй –	+	кортеж вида ('''35''', ‘Resource temporarily unavailable’), где первый элемент – числовой код ошибки, а второй –
-	текстовая строка-пояснение. При отсутствии данных генерируется ошибка 35, которую мы и игнорируем (pass). Здесь	+	текстовая строка-пояснение. При отсутствии данных генерируется ошибка '''35''', которую мы и игнорируем (''pass''). Здесь
-	мы получаем то же ожидание данных, но уже реализованное самим кодом Python. Но преимущество здесь в том, что	+	мы получаем то же ожидание данных, но уже реализованное самим кодом [[Python]]. Но преимущество здесь в том, что
-	вместо оператора pass можно реализовать любую обработку. Например, переходить к опросу другого сокета.	+	вместо оператора ''pass'' можно реализовать любую обработку. Например, переходить к опросу другого сокета.

	===logserver.py===		===logserver.py===

Mim: добавил отступы, заменил "else: if" на "elif"

2008-11-19T23:52:02Z

добавил отступы, заменил "else: if" на "elif"

← Предыдущая		Версия 23:52, 19 ноября 2008
Строка 266:		Строка 266:
	#!/usr/bin/python		#!/usr/bin/python
	# -- coding: utf-8 --		# -- coding: utf-8 --
		+
	import os, socket, time, signal, select		import os, socket, time, signal, select
		+
	class LogServer:		class LogServer:
-	def __init__(self, sockfile='./lserv.sock',	+	def __init__(self, sockfile='./lserv.sock',
-	logfile='./lserv.log',	+	logfile='./lserv.log',
-	maxqueue=5):	+	maxqueue=5):
-	self.logfilename = logfile	+	self.logfilename = logfile
-	self.openlog()	+	self.openlog()
-	self.sockfilename = sockfile	+	self.sockfilename = sockfile
-	try:	+	try:
-	if os.path.exists(sockfile):	+	if os.path.exists(sockfile):
-	os.unlink(sockfile)	+	os.unlink(sockfile)
-	except:	+	except:
-	raise 'error'	+	raise 'error'
-	self.socket = socket.socket(socket.AF_UNIX)	+
-	self.socket.bind(sockfile)	+	self.socket = socket.socket(socket.AF_UNIX)
-	self.socket.listen(maxqueue)	+	self.socket.bind(sockfile)
-	signal.signal(signal.SIGHUP, self.reinit)	+	self.socket.listen(maxqueue)
-	signal.signal(signal.SIGINT, self.stop)	+
-	signal.signal(signal.SIGTERM, self.stop)	+	signal.signal(signal.SIGHUP, self.reinit)
-	self.writelog('===> LogServer started')	+	signal.signal(signal.SIGINT, self.stop)
-	def openlog(self):	+	signal.signal(signal.SIGTERM, self.stop)
-	self.log = open(self.logfilename, 'a+')	+
-	def writelog(self, message):	+	self.writelog('===> LogServer started')
-	self.log.write('%s: %s\n' % (time.asctime(), message))	+
		+	def openlog(self):
		+	self.log = open(self.logfilename, 'a+')
		+
		+	def writelog(self, message):
		+	self.log.write('%s: %s\n' % (time.asctime(), message))
		+
		+	def reinit(self, signum, frame):
		+	self.log.close()
		+	self.openlog()
		+	self.start()
		+
		+	def start(self):
		+	rsocks = []
		+	wsocks = []
		+	rsocks.append(self.socket)
		+	senders = {}
		+	while 1:
		+	try:
		+	reads, writes, errs = select.select(rsocks, wsocks, [])
		+	except:
		+	return
		+
		+	for sock in reads:
		+	if sock == self.socket:
		+	client, name = sock.accept()
		+	rsocks.append(client)
		+	elif not `sock` in senders.keys():
		+	sender = sock.recv(1024)
		+	sock.send('Sender OK')
		+	senders['sock'] = sender
		+	else:
		+	message = sock.recv(1024)
		+	sock.send('Message OK')
		+	self.writelog('[%s] %s' % (senders['sock'], message))
		+	rsocks.remove(sock)
		+	del senders['sock']
		+
		+	def stop(self, signum, frame):
		+	self.writelog('===> LogServer stopped [signal %s]' % (signum))
		+	self.log.close()
		+	os.unlink(self.sockfilename)

-	def reinit(self, signum, frame):
-	self.log.close()
-	self.openlog()
-	self.start()
-	def start(self):
-	rsocks = []
-	wsocks = []
-	rsocks.append(self.socket)
-	senders = {}
-	while 1:
-	try:
-	reads, writes, errs = select.select(rsocks, wsocks, [])
-	except:
-	return
-	for sock in reads:
-	if sock == self.socket:
-	client, name = sock.accept()
-	rsocks.append(client)
-	else:
-	if not `sock` in senders.keys():
-	sender = sock.recv(1024)
-	sock.send('Sender OK')
-	senders['sock'] = sender
-	else:
-	message = sock.recv(1024)
-	sock.send('Message OK')
-	self.writelog('[%s] %s' % (senders['sock'], message))
-	rsocks.remove(sock)
-	del senders['sock']
-	def stop(self, signum, frame):
-	self.writelog('===> LogServer stopped [signal %s]' % (signum))
-	self.log.close()
-	os.unlink(self.sockfilename)
	if __name__ == '__main__':		if __name__ == '__main__':
-	serv = LogServer(maxqueue=3)	+	serv = LogServer(maxqueue=3)
-	serv.start()	+	serv.start()
	</source>		</source>

Yaleks: /* Задачи многозадачности */

2008-07-09T13:02:45Z

Задачи многозадачности

← Предыдущая		Версия 13:02, 9 июля 2008
Строка 30:		Строка 30:
	исполняются), переключение их контекста происходит заметно быстрее,		исполняются), переключение их контекста происходит заметно быстрее,
	чем контекста процесса. Благодаря этому можно распараллеливать		чем контекста процесса. Благодаря этому можно распараллеливать
-	задачи с заметно меньшими затратами. Хорошим примером может служить производительность Apache 2.x (см. обзор в [[LXF77]]).	+	задачи с заметно меньшими затратами. Хорошим примером может служить производительность Apache 2.x (см. обзор в [[LXF77:Apache 2.2\|LXF77]]).

	Хватит, пожалуй, теории. Посмотрим, какие средства предоставляет		Хватит, пожалуй, теории. Посмотрим, какие средства предоставляет

Yaleks в 07:33, 20 марта 2008

2008-03-20T07:33:10Z

← Предыдущая		Версия 07:33, 20 марта 2008
Строка 1:		Строка 1:
		+	{{Цикл/Python}}
		+
	==Задачи многозадачности==		==Задачи многозадачности==
	''часть 1 '''Сергей Супрунов''' открывает новый цикл статей, в котором будут более полно освещены некоторые практические моменты разработки приложений на языке Python. Начнём, пожалуй, с вопросов параллельных вычислений...''		''часть 1 '''Сергей Супрунов''' открывает новый цикл статей, в котором будут более полно освещены некоторые практические моменты разработки приложений на языке Python. Начнём, пожалуй, с вопросов параллельных вычислений...''

Yaleks: викификация

2008-03-19T19:08:26Z

викификация

← Предыдущая		Версия 19:08, 19 марта 2008
Строка 47:		Строка 47:
	import socket # импортируем модуль		import socket # импортируем модуль
	s = socket.socket(socket.AF_UNIX) # создаём сокет домена AF_UNIX		s = socket.socket(socket.AF_UNIX) # создаём сокет домена AF_UNIX
-	s.bind(‘/tmp/test.~~sock’~~) # привязываем его к файлу	+	s.bind('/tmp/test.sock') # привязываем его к файлу
	s.listen(1) # начинаем прослушивать		s.listen(1) # начинаем прослушивать
	conn = s.accept() # ждём подключения		conn = s.accept() # ждём подключения
-	conn.send(~~‘HELO’~~) # дождавшись, отправляем клиенту строку	+	conn.send('HELO') # дождавшись, отправляем клиенту строку
	data = conn.recv(1024) # получаем от клиента данные		data = conn.recv(1024) # получаем от клиента данные
	s.close() # закрываем сокет		s.close() # закрываем сокет
Строка 66:		Строка 66:
	import socket # импортируем модуль		import socket # импортируем модуль
	c = socket.socket(socket.AF_UNIX) # создаём сокет такого-же домена		c = socket.socket(socket.AF_UNIX) # создаём сокет такого-же домена
-	c.connect(‘/tmp/test.~~sock’~~) # подключаемся к сокету сервера	+	c.connect('/tmp/test.sock') # подключаемся к сокету сервера
	greeting = c.recv(1024) # принимаем строку приветсвия		greeting = c.recv(1024) # принимаем строку приветсвия
-	c.send(~~‘Hello~~, server!’) # отправляем свои данные	+	c.send('Hello, server!') # отправляем свои данные
	c.close() # закрываем соединение		c.close() # закрываем соединение
	</source>		</source>
Строка 246:		Строка 246:
	while(1):		while(1):
	try:		try:
-	data = sock.recv()	+	data = sock.recv()
-	except socket.error, errcode:	+	except socket.error, errcode:
	if errcode[0] == 35:		if errcode[0] == 35:
-	pass	+	pass
	else:		else:
-	raise(socket.error)	+	raise(socket.error)
	</source>		</source>

Строка 266:		Строка 266:
	import os, socket, time, signal, select		import os, socket, time, signal, select
	class LogServer:		class LogServer:
-	def __init__(self, sockfile=’./lserv.~~sock’~~,	+	def __init__(self, sockfile='./lserv.sock',
-	logfile=’./lserv.~~log’~~,	+	logfile='./lserv.log',
	maxqueue=5):		maxqueue=5):
	self.logfilename = logfile		self.logfilename = logfile
Строка 276:		Строка 276:
	os.unlink(sockfile)		os.unlink(sockfile)
	except:		except:
-	raise ~~‘error’~~	+	raise 'error'
	self.socket = socket.socket(socket.AF_UNIX)		self.socket = socket.socket(socket.AF_UNIX)
	self.socket.bind(sockfile)		self.socket.bind(sockfile)
Строка 283:		Строка 283:
	signal.signal(signal.SIGINT, self.stop)		signal.signal(signal.SIGINT, self.stop)
	signal.signal(signal.SIGTERM, self.stop)		signal.signal(signal.SIGTERM, self.stop)
-	self.writelog(‘===> LogServer ~~started’~~)	+	self.writelog('===> LogServer started')
	def openlog(self):		def openlog(self):
-	self.log = open(self.logfilename, ‘a+’)	+	self.log = open(self.logfilename, 'a+')
	def writelog(self, message):		def writelog(self, message):
-	self.log.write(‘%s: %s\n’ % (time.asctime(), message))	+	self.log.write('%s: %s\n' % (time.asctime(), message))
-	27	+
	def reinit(self, signum, frame):		def reinit(self, signum, frame):
	self.log.close()		self.log.close()
Строка 310:		Строка 310:
	if not `sock` in senders.keys():		if not `sock` in senders.keys():
	sender = sock.recv(1024)		sender = sock.recv(1024)
-	sock.send(~~‘Sender OK’~~)	+	sock.send('Sender OK')
-	senders[`sock`] = sender	+	senders['sock'] = sender
	else:		else:
	message = sock.recv(1024)		message = sock.recv(1024)
-	sock.send(~~‘Message OK’~~)	+	sock.send('Message OK')
-	self.writelog(‘[%s] %s’ % (senders[`sock`], message))	+	self.writelog('[%s] %s' % (senders['sock'], message))
	rsocks.remove(sock)		rsocks.remove(sock)
-	del senders[`sock`]	+	del senders['sock']
	def stop(self, signum, frame):		def stop(self, signum, frame):
-	self.writelog(‘===> LogServer stopped [signal %s]’ % (signum))	+	self.writelog('===> LogServer stopped [signal %s]' % (signum))
	self.log.close()		self.log.close()
	os.unlink(self.sockfilename)		os.unlink(self.sockfilename)
-	if __name__ == ~~‘__main__’~~:	+	if __name__ == '__main__':
	serv = LogServer(maxqueue=3)		serv = LogServer(maxqueue=3)
	serv.start()		serv.start()
Строка 333:		Строка 333:
	import sys, socket, time		import sys, socket, time
	class LogClient:		class LogClient:
-	def __init__(self, sender=~~’generic client’~~,	+	def __init__(self, sender='generic client',
-	sockfile=’./lserv.~~sock’~~,	+	sockfile='./lserv.sock',
	buffersize=1024,		buffersize=1024,
	testmode=0):		testmode=0):
Строка 347:		Строка 347:
	self.socket.connect(self.sockfile)		self.socket.connect(self.sockfile)
	self.socket.send(self.sender)		self.socket.send(self.sender)
-	if self.socket.recv(self.buffersize) == ~~‘Sender OK’~~:	+	if self.socket.recv(self.buffersize) == 'Sender OK':
	if self.testmode:		if self.testmode:
	time.sleep(5)		time.sleep(5)
	self.socket.send(message)		self.socket.send(message)
-	if not self.socket.recv(self.buffersize) == ~~‘Message OK’~~:	+	if not self.socket.recv(self.buffersize) == 'Message OK':
-	print ~~‘Ошибка~~: нет подтверждения ~~Message’~~	+	print 'Ошибка: нет подтверждения Message'
	else:		else:
-	print ~~‘Ошибка~~: нет подтверждения ~~Sender’~~	+	print 'Ошибка: нет подтверждения Sender'
	self.socket.close()		self.socket.close()
-	if __name__ == ~~‘__main__’~~:	+	if __name__ == '__main__':
	sendername = sys.argv[1]		sendername = sys.argv[1]
	client = LogClient(sender=sendername, testmode=1)		client = LogClient(sender=sendername, testmode=1)
-	client.writelog(~~‘Test message’~~)	+	client.writelog('Test message')
	</source>		</source>

Строка 371:		Строка 371:
	pid = os.fork()		pid = os.fork()
	if pid == 0:		if pid == 0:
-	client = LogClient(sender=~~’client~~%d’ % i, testmode=1)	+	client = LogClient(sender='client%d' % i, testmode=1)
-	client.writelog(~~‘Test~~ from client%d’ % i)	+	client.writelog('Test from client%d' % i)
	os._exit(0)		os._exit(0)
	else:		else:
-	print ~~‘Start~~ child[%d]’ % pid	+	print 'Start child[%d]' % pid
	</source>		</source>