fsq 0.2.5

从pip

sudo pip install fsq==0.2.5

从源安装v0.2.5

curl https://github.com/axialmarket/fsq/archive/version_0.2.5.tar.gz | tar vzxf -
cd fsq
sudo python setup.py install

安装队列

要安装队列，只需运行：

$ fsq install a_queue

或者通过python api：

>>> import fsq
>>> fsq.install(a_queue)

安装队列将在FSQ_ROOT（/var/fsq/）中创建目录：

/var/fsq/a_queue
├── done
├── fail
├── queue
└── tmp

排队工作

要将工作排队到a_queue队列，只需运行：

$ echo "data" | fsq enqueue a_queue args to enqueue

或者来自python api：

>>> import fsq
>>> # enqueue a string
>>> fsq.senqueue('a_queue', 'data', 'args', 'to', 'enqueue')
>>> # ... or a file
>>> fsq.senqueue('a_queue', '/path/to/data.file', 'args', 'to', 'enqueue')

排队将文件添加到a_queue：

/var/fsq/a_queue
├── done
├── fail
├── queue
|   └── _20131005205643_0_25577_mss_0_args_to_enqueue
└── tmp

处理工作

要处理作业，请使用fsq scan程序：

$ # echo gets "args", "to", "enqueue" as $1..$3 and "data" on stdin
$ fsq scan a_queue echo
args to enqueue

或者来自python api：

>>> import fsq
>>> for work in fsq.scan('a_queue'):
...     print " ".join(work.arguments)
...     fsq.done('a_queue')
args to enqueue

已成功完成的工作移动到已完成目录：

/var/fsq/a_queue
├── done
|   └── _20131005205643_0_25577_mss_0_args_to_enqueue
├── fail
├── queue
└── tmp

当fsq扫描每个工作项时，它获得对该工作项的独占锁。 文件，因此可以安全地在上并行运行多个扫描进程（或线程） 同样的队伍，不怕重复劳动。

处理工作失败

如果在处理过程中工作失败：

$ fsq scan a_queue sh -c 'exit 100'

或者来自python api：

>>> import fsq
>>> for work in fsq.scan('a_queue'):
...     fsq.fail('a_queue')

失败的工作将移动到失败目录：

/var/fsq/a_queue
├── done
├── fail
|   └── _20131005205643_0_25577_mss_0_args_to_enqueue
├── queue
└── tmp

工作也可能暂时失败，这将导致工作停留在 queue目录，直到它早于FSQ_TTL秒，或者直到 它已经尝试了超过FSQ_MAX_TRIES次，但没有成功：

$ # exit code 111 indicates temporary failure
$ FSQ_MAX_TRIES=2 fsq scan a_queue sh -c 'exit 100'

或者来自python api：

>>> import fsq
>>> fsq.set_const('FSQ_MAX_TRIES', 2)
>>> for work in fsq.scan('a_queue'):
...     fsq.fail_tmp(work)

工作项的名称将更改以指示该项已失败 一次：

/var/fsq/a_queue
├── done
├── fail
├── queue
|   └── _20131005205643_0_25577_mss_1_args_to_enqueue
└── tmp

排长队

要暂时停止对任何队列的所有扫描，只需使用fsq down 程序：

$ fsq down a_queue

或者来自python api：

>>> import fsq
>>> fsq.down('a_queue')

在a_queue目录中创建名为down的常规文件 阻止扫描处理队列：

/var/fsq/a_queue
├── done
├── down
├── fail
├── queue
|   └── _20131005205643_0_25577_mss_0_args_to_enqueue
└── tmp

要重新启动队列，只需使用fsq up程序：

$ fsq up a_queue

或者来自python api：

>>> import fsq
>>> fsq.up('a_queue')

它删除down文件，并允许正确扫描队列 再一次。

tmp目录

fsq在一个队列中使用tmp目录来确保 所有项目都按原子顺序排队。

fsq文件名

_20120710213904_0_13044_mss_0_args_to_enqueue
_20120710213904_1_13044_mss_0_args_to_enqueue
+|-----+------| + |-+-| |+| + |------+------|
|      |        |   |    |  |        |
|      |        |   |    |  |        +-> FSQ_DELIMITER seperated
|      |        |   |    |  |            arguments
|      |        |   |    |  +-> tries: number of failed attempts
|      |        |   |    |      to process
|      |        |   |    +-> hostname: the name of the host on
|      |        |   |        which the work-item was enqueued.
|      |        |   +-> pid of the process which enqueued the
|      |        |       work-item
|      |        +-> entropy: should a work-item be generated
|      |            with the same arguments, pid, hostname
|      |            and timestamp, entropy is incremented to
|      |            generate uniqueness.
|      +-> timestamp in FSQ_TIMEFMT format
+-> FSQ_DELIMITER used at enqueue time

其他贡献来自：