Видео ролики бесплатно онлайн

Смотреть красавицы видео

Официальный сайт 4stupeni 24/7/365

Смотреть видео бесплатно

wiz 06.02.2011 15:21

PythonВеб-сервер своими руками. Часть 4 — раздача файлов

Переходим к более практической части. Хардкодом побаловались, далее по плану идёт раздача файлов.

Я пока смутно представляю какой должна быть реализация, но зато примерно знаю как можно проверить её правильность. Поэтому эти знания мы сейчас выразим в виде теста, к несуществующему пока коду. Такой подход называется Test-driven Development или TDD. Тоесть мы сначала строим измеритель выхлопа, а потом уже на другом конце собираем карбюратор, соответствующий заданым параметрам (= Контринтуитивный манёвр, но частенько помогает определиться с API ещё до написания кода, который потом, во время изменения задачи придётся переписывать. А зачем делать двойную работу?

Обработчики являются как бы плагинами к серверу, он от них никак не зависит, и поэтому должны лежать в отдельном модуле (handlers.py).

 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
class TestHandlers(object):
def setup(self):
self.server = HTTPServer()
self.client = MockClient(self.server)

def test_static(self):
"""Раздача файлов с диска"""

self.server.register(lambda r: True, serve_static) # обслуживать все запросы как файл-сервер

eq_('404', self.client('/give-me-nice-404')<0><1>)

reply, headers, body = self.client('/handlers.py') # файл из каталога сервера
data = open('handlers.py').read() # загружаем тот же файл вручную
eq_(body, data) # проверяем содержимое
eq_(int(headers<'CONTENT-LENGTH'>), len(data)) # и заголовок с длиной, которую сервер должен нам посчитать



Функцию serve_static надо будет импортировать в начале тестов, а в handlers.py сделать заглушку:
1
2
def serve_static(request):
request.reply(body="your file %s is being downloaded. wait 1 minute for a link or send SMS to numer 100500")



Тесты начнут дружно валиться, но теперь понятно что должно быть внутри функции:
1
2
3
4
5
6
7
8
def serve_static(request):
try:
data = open(request.url<1:>).read() # отрезаем начальный / из адреса и считываем файлы
except IOError as err: # если что-то не получилось, ловим ошибку
if err.errno == 2: # ничего особенного, просто нет такого файла
return request.reply('404', 'Not found', '%s: not found' % request.url)
raise # всё остальное - не наше дело
request.reply(body=data, content_length=len(data))



Теперь всё проходит. Можно сделать «однострочный веб сервер» для раздачи файлов из текущего каталога в баше, который можно вызывать через `python -m serve`. Пока оно не установлено в пути python из любого каталога конечно не прокатит, но из возле самого сервера работать вполне будет.
1
2
3
4
5
if __name__ == '__main__':
server = HTTPServer()
from handlers import serve_static
server.register(lambda _: True, serve_static)
server.serve()



Запускаем, пробуем:

1
2
3
4
curl http://localhost:8000/handlers.py
def serve_static(request):
try:
...



Работает. Пробуем дальше:

1
2
3
4
5
6
curl http://localhost:8000/../../../../../../../../../../../etc/passwd
root:x:0:0:root:/root:/bin/bash
daemon:x:1:1:daemon:/usr/sbin:/bin/sh
bin:x:2:2:bin:/bin:/bin/sh
sys:x:3:3:sys:/dev:/bin/sh
...



Ой! К счастью сервер запущен не от рута и /etc/shadow в безопасности. Но сервер при этом жёстко крашнется:

1
2
3
4
5
6
GET /../../../../../../../../../../../etc/shadow {'HOST': 'localhost:8000', 'ACCEPT': '*/*', 'USER-AGENT': 'curl/7.21.0 (x86_64-pc-linux-gnu) libcurl/7.21.0 OpenSSL/0.9.8o zlib/1.2.3.4 libidn/1.18'}
Traceback (most recent call last):
...
File "handlers.py", line 5, in serve_static
data = open(request.url<1:>).read()
IOError: <errno> Permission denied: '../../../../../../../../../../../etc/shadow'</errno>



Сразу допишем в test_handlers вредный тест, который будет рушить «сервер» в комфортной обстановке:

1
2
self.server.register(lambda r: r.url == '/crash/me/', lambda r: no_you)
eq_('500', self.client('/crash/me/')<0><1>)


Тесты начали фэйлиться с «NameError: global name 'no_you' is not defined». Замечательно, то что нужно.

В каждом хэндлере всех ошибок не отловишь, да и полагаться на их будущих авторов тоже не стоит. «Хочешь чтобы было хорошо — сделай это сам!». Где у нас есть место, в котором можно раз и навсегда защитить сервер от крашей по причине ошибок хэндлеров? Они вызываются из диспетчера on_request, пристегнём его try-мнями безопасности:
1
2
3
4
5
6
7
8
9
try:  # всё что далее, под защитой
for pattern, handler in self.handlers:
if pattern(request):
handler(request)
return True
except Exception as err: # ловим все ошибки
request.reply('500', 'Infernal server error', 'Ай нанэ-нанэ...') # и сообщаем в ответе
return False # обязательно заканчиваем выполнение после request.reply чтобы не слать уже в закрытое соединение
# соединение закрыто, сервер продолжает свою работу


Конечно, это не защитит от всяких фатальных ошибок типа вызывающих core dump, но уже что-то. Тесты теперь ловят свой законный «груз 500», но человек, заглянувший браузером останется в непонятках и будет зол. Особенно если это сам разработчик в поисках проблемы. Питон позволяет не просто отлавливать код и сообщение ошибки, но и ситуацию, в которой она возникла. А заполучить это нам поможет штатный модуль traceback.

Сделаем более детальный тест:
1
2
3
request, headers, body = self.client('/crash/me/')
eq_(request<1>, '500')
assert 'NameError' in body, body



Выражение assert это способ языка проверить очень-важное-условие. assert False — всегда будет вызывать исключение AssertionError. А чтобы сразу было видно, что не понравилось условию, вторым «аргументом» assert идёт тело ответа. Прямо сейчас нам оттуда просто выражают сожаление, но ничего конкретного не сообщают.

Немного изменим обработку ошибки:
1
request.reply('500', 'Infernal server error', traceback.format_exc())



curl стал показывать трейсбек и ошибку, что значительно облегчит написание и отладку обработчиков:
1
2
3
4
...
File "handlers.py", line 5, in serve_static
data = open(request.url<1:>).read()
IOError: <errno> Permission denied: '../../../../../../../../../../../etc/shadow'</errno>



Этому хаку уже сто лет 21 год в обед и нам ещё повезло, что open не умеет выполнять команды внутри скобок типа `mail [email protected] < /etc/shadow` и прочие шелловские штучки, которым были подвержены в детском возрасте многие демоны. Но всё же, даже такая штука весьма неприятна даже если сервер запущен от nobody:nogroup.

Сегодня — день TDD, поэтому сразу заготавливаем проверку. Это уже не для сервера в целом, а для конкретного хэндлера, поэтому и отправляется в его набор test_static:
1
eq_('404', self.client('/../../../../../../../../../../../etc/passwd')<0><1>)



Убедившись, что nosetests выдаёт наш «законный» AssertionError: '404' != '200', отправляемся писать фикс.

В библиотеке os.path есть много интересных функций, поэкспериментировав с которыми можно найти одну, которая выдаёт, что указаный путь выходит за уровень начального:
1
2
3
4
5
6
from os.path import relpath

def serve_static(request):
path = request.url<1:> # сразу отрезаем кусочек из урла, он нам дальше ещё везде пригодится
if relpath(path).startswith('..'): # побег! аларм!
return request.reply('404', 'Not found', '%s: not found' % path) # отказываемся обслуживать запрос



Что-то я уже подзадолбался писать «return request.reply()», тем более, что сервер в итоге и так ещё потом пытается ловить ошибки. А ведь 4хх и 5хх это именно ошибки и есть. Вынесем их в отдельный класс исключений, которые затем можно будет везде бросать и ловить:

1
2
class HTTPError(Exception):
pass



И всё. Остальные могут его импортировать и пользоваться. Сделаем для него специальный способ обработки в диспетчере:
 1
2
3
4
5
6
7
8
9
10
...
except HTTPError as error:
err_code = error.args<0> # передаём код ошибки в аргументе исключения
reply = { # сообщения стандартные
404: 'Not found',
403: 'Permission denied',
}<err_code> # питонский аналог switch/case
request.reply(str(err_code), reply, "%s: %s" % (reply, request.url)) # формируем ответ
return False # и отваливаемся
...</err_code>



После перевода ошибок на рельсы HTTPError оставшиеся ошибки из файловой системы транслируются в коды HTTP достаточно тривиально.

Выдавать файлы из текущего каталога это забавно, но хочется всё же указать привычный /var/www, а может даже не один. Тоесть понадобится система альясов url ? path, а значит нужна связь между паттерном и хэндлером. Можно было бы сделать специальный класс с конструктором (url, root) и методами pattern & handler, которые через экземпляр класса бы знали свои начальные параметры. Но «объекты это замыкания для бедных» © Norman Adams. Действительно, зачем городить целый класс, потом создавать его экземпляр, потом брать его методы и засовывать в сервер, когда нам нужно всего лишь объединить область видимости уже готовой функции с паттерном, который отловит соответствующий URL.

Первым делом, первым делом — юнит тесты... Завернём раздатчик статики так, чтобы функция выдавала две других функции и передадим это хозяйство через развёртывание позиционных аргументов:
1
self.server.register(*serve_static('/', '.'))


Ровно тоже самое, что и было: все урлы раздаются из текущего каталога.

Нынешнюю serve_static переименуем в handler и завернём внутрь новой serve_static(url, root):
1
2
3
def serve_static(url, root):
def handler(request):
...



Теперь у нас есть создание функции внутри другой функции. При этом изнутри handler будут доступны также ещё url и root из «родительской функции». Добавим паттерн и возврат двух свежесозданных функций:
 1
2
3
4
5
6
7
8
9
10
11
def serve_static(url, root):
cut = len(url) # сразу подсчитаем сколько надо отрезать от url для преобразования в путь относительно root

def pattern(request):
return request.url.startswith(url)

def handler(request):
path = "%s/%s" % (root, request.url<cut:>) # превращаем путь из URL в путь на ФС
...

return pattern, handler</cut:>


Замыкания потому так и называются, что, после того, как возврат произведён, всё состояние как бы перестаёт существовать, как река, в которую нельзя войти дважды. Но функции, созданные (они на самом деле создаются на ходу - можете проверить их id) продолжают иметь доступ к этому «висящему в пустоте» контексту и всем его переменным. Поэтому единожды посчитаная длина базового URL продолжает оставаться доступной для всего кода порождённого внутри.

Тесты как обычно показывают, что код в порядке и при переезде ничего не отломилось.

Другой важной задачей файлого сервера, помимо отдавания файлов, является... не-отдавание файлов когда это возможно. Это называется «кэш на стороне клиента» и обеспечивается с помощью пары заголовков If-Modified-Since/Last-Modified и кода HTTP 304: Not modified.

Для того чтобы договориться о том, что надо или не надо передавать содержимое файла сервер посылает заголовок Last-Modified с датой последнего изменения по GMT в формате RFC1123: '%a, %d %b %Y %H:%I:%S GMT'. Чтобы получить эту дату (и ещё другие вещи, которые тоже пригодятся) используем os.stat:
1
2
&gt;&gt;&gt; os.stat('./handlers.py')
posix.stat_result(st_mode=33188, st_ino=10881370L, st_dev=2097L, st_nlink=1, st_uid=1000, st_gid=1000, st_size=860L, st_atime=1296987898, st_mtime=1296987898, st_ctime=1296987898)


Отсюда нам интересны st_mtime (время изменения), st_size (размер) и st_mode (вдруг это не файл вообще). Если такого узла в файловой системе не будет, возникнет исключение OSError/2 (а не, IOError, как в случае с open). С каталогами мы разберёмся в следующей части, а дата и размер берутся достаточно легко.
1
2
3
4
5
6
7
try:
stat = os.stat(path) # собираем информацию
mod_time = time.strftime(DATE_RFC1123, time.gmtime(stat.st_mtime)) # форматируем время
data = open(path).read() # пока что продолжаем читать содержимое
except (OSError, IOError) as err: # ловим сразу несколько исключений
...
request.reply(body=data, content_length=stat.st_size, last_modified=mod_time) # размер берём сразу из stat, добавляем дату



Клиент, увидев дату, запомнит её и в следующий раз отправит вместе с запросом в заголовке If-Modified-Since, который надо распарсить и сравнить с датой файла. Сразу оформим это в виде теста:
1
2
3
4
# ... предыдущий запрос к handlers.py ... #
reply, headers, body = self.client('/handlers.py', if_modified_since=headers<'LAST-MODIFIED'>)
eq_(reply, <'HTTP/1.0', '304', 'Not modified'>)
eq_(body, '')



И сделаем закорачивание обработки сразу после stat:
1
2
3
4
5
6
7
if 'IF-MODIFIED-SINCE' in request.headers:
try:
request_mtime = time.mktime(time.strptime(request.headers<'IF-MODIFIED-SINCE'>, DATE_RFC1123))
except ValueError:
request_mtime = None # в заголовках мусор
if request_mtime and request_mtime &lt; stat.st_mtime:
return request.reply('304', 'Not modified', '') # сам файл уже не читаем



Вот и всё. Осталось починить дефолтный сервер, а заодно добавить немного настроек.

В python 2.7 появился очередной модуль разбора аргументов командной строки argparse, который довольно неплох. Для предыдущих версий его можно поставить из pip. А можно и не ставить и сделать так, чтобы сервер запускался и без него. import ничем не хуже других инструкций питона и бросает самые обычные исключения, которые можно просто отловить и обойти.
 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
if __name__ == '__main__':
from handlers import serve_static

port, root = 8000, '.' # значения по-умолчанию

try:
import argparse
parser = argparse.ArgumentParser()
options = parser.parse_args()
except ImportError:
pass # нету, и не очень-то и хотелось...

server = HTTPServer(port=port)
server.register(*serve_static('/', root))
server.serve()



Код теперь попытается разобрать командную строку и скромно откажется принимать какие-либо аргументы кроме --help/-h. Допишем разбор порта и корневого каталога для раздачи:
1
2
3
4
parser.add_argument('--port', nargs='?', type=int, default=port)  # преобразуем аргумент сразу к типу int
parser.add_argument('--root', nargs='?', type=str, default=root) # str не обязательно, они и так будут строками
options = parser.parse_args()
port, root = options.port, options.root # вытаскиваем улов



Формат очень простой: полное имя переменной (короткое он сам сделает), количество аргументов (? - один необязательный, * - много необязательных или фиксированое число), в какой тип преобразовывать (если надо) и значение по-умолчанию (None, если не указывать). Там есть ещё другие интересные опции, но этих нам хватит. Если полное имя написать без «--», то получится позиционный аргумент.

Результаты регистрации аргументов можно посмотреть вызывав справку:
1
2
3
4
5
6
7
$ python -m serve -h
usage: serve.py <-h> <--port <port>> <--root <root>>

optional arguments:
-h, --help show this help message and exit
--port </root></port><port>
--root <root></root></port>



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

(весь код в сборе)


Тэги: http nose ownhands python server tdd tutorial unittest велосипед
+ 12 -
Похожие Поделиться

digiwhite 06.02.2011 20:35 #
+ 0 -
Спасибо!

Кстати, wiz, посоветуйте пожалуйста IDE для Python. Eric почему-то вызывает отторжение.
wiz 06.02.2011 20:37 #
+ 0 -
UNIX is the IDE (;

Все статьи писались в gedit. Свои проекты на удалённых дев-серверах корячу в емаксе и то только из-за копипаста и подсветки.
digiwhite 06.02.2011 20:43 #
+ 0 -
Ясно, спасибо :) Пойду в гугл, пошукаю что-нибудь адекватное для Vim :)
derfenix 06.02.2011 21:44 #
+ 0 -
найдёшь вдруг - будь добр свистни %) а то я не нашёл ничего, кроме сниппетов :))
digiwhite 06.02.2011 22:11 #
+ 0 -
Договорились.
Midler 07.02.2011 01:08 #
+ 0 -
Если хочется немного поиграться то можно bpython.
Интерпретатор Python с подсветкой, автодополнением и документацией.
kstep 09.02.2011 20:31 #
+ 0 -
Есть ещё ipython, тоже неплох. Особенно мне нравится, что можно автодополнять выражение
from module import <и тут по табу автодополняются импортируемые из модуля объекты>
В bpython я такого вроде не видел.
leonike 06.02.2011 21:46 #
+ 2 -
Из бесплатных решений неплохо зарекомендовал себя eclipse + pydev.
Из платных можно выделить Wing IDE, pycharm, komodo.
А здесь преставлен широкий список с небольшим описанием: http://wiki.python.org/moin/IntegratedDevelopmentEnvironments, http://wiki.python.org/moin/PythonEditors
DropSQL 19.02.2011 13:51 #
+ 1 -
Я за PyCharm :)
wiz 07.02.2011 12:02 #
+ 0 -
Кстати, как статьи по объёму? 200± строк как сейчас это ок или много? Или может можно смело до 400 догонять?
derfenix 07.02.2011 12:20 #
+ 1 -
200 норм, но 400 уже сложно переварить за раз будет - всё-равно частями чиататься будет :)
blackraven 07.02.2011 12:12 #
+ 1 -
Афтар, пеши есчо :)
А серьезно - жжошь, так держать!
gpont 02.06.2012 12:12 #
+ 0 -
Мне необходимо передать через сокеты не текстовой файл. Как мне это сделать?

Смотреть онлайн бесплатно

Онлайн видео бесплатно


Смотреть русское с разговорами видео

Online video HD

Видео скачать на телефон

Русские фильмы бесплатно

Full HD video online

Смотреть видео онлайн

Смотреть HD видео бесплатно

School смотреть онлайн