golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
197 B
Del
OK
asam.cpython-310.pyc
7.9 KB
Del
OK
auth.cpython-310.pyc
1.89 KB
Del
OK
bgp.cpython-310.pyc
12.55 KB
Del
OK
cache.cpython-310.pyc
10.98 KB
Del
OK
cloud.cpython-310.pyc
4.16 KB
Del
OK
config.cpython-310.pyc
1.08 KB
Del
OK
ddns.cpython-310.pyc
6.7 KB
Del
OK
digicertapi.cpython-310.pyc
16.23 KB
Del
OK
doc.cpython-310.pyc
1.76 KB
Del
OK
drac.cpython-310.pyc
4.15 KB
Del
OK
error.cpython-310.pyc
771 B
Del
OK
event.cpython-310.pyc
2.32 KB
Del
OK
f5.cpython-310.pyc
8.29 KB
Del
OK
fileserver.cpython-310.pyc
17.12 KB
Del
OK
git_pillar.cpython-310.pyc
3.54 KB
Del
OK
http.cpython-310.pyc
2.55 KB
Del
OK
jobs.cpython-310.pyc
13.26 KB
Del
OK
launchd.cpython-310.pyc
1.49 KB
Del
OK
lxc.cpython-310.pyc
13.3 KB
Del
OK
manage.cpython-310.pyc
21.71 KB
Del
OK
mattermost.cpython-310.pyc
4.21 KB
Del
OK
mine.cpython-310.pyc
1.79 KB
Del
OK
nacl.cpython-310.pyc
8.46 KB
Del
OK
net.cpython-310.pyc
27.7 KB
Del
OK
network.cpython-310.pyc
2.59 KB
Del
OK
pagerduty.cpython-310.pyc
3.96 KB
Del
OK
pillar.cpython-310.pyc
4.25 KB
Del
OK
pkg.cpython-310.pyc
1.37 KB
Del
OK
queue.cpython-310.pyc
8.14 KB
Del
OK
reactor.cpython-310.pyc
4.32 KB
Del
OK
salt.cpython-310.pyc
4.58 KB
Del
OK
saltutil.cpython-310.pyc
15.88 KB
Del
OK
sdb.cpython-310.pyc
2.54 KB
Del
OK
smartos_vmadm.cpython-310.pyc
7.99 KB
Del
OK
spacewalk.cpython-310.pyc
7.54 KB
Del
OK
ssh.cpython-310.pyc
1000 B
Del
OK
state.cpython-310.pyc
8.22 KB
Del
OK
survey.cpython-310.pyc
5.07 KB
Del
OK
test.cpython-310.pyc
2.65 KB
Del
OK
thin.cpython-310.pyc
1.81 KB
Del
OK
vault.cpython-310.pyc
10.01 KB
Del
OK
venafiapi.cpython-310.pyc
5.57 KB
Del
OK
virt.cpython-310.pyc
13.15 KB
Del
OK
vistara.cpython-310.pyc
4.39 KB
Del
OK
winrepo.cpython-310.pyc
5.14 KB
Del
OK
Edit: queue.cpython-310.pyc
o �xea# � @ s� d Z ddlZddlmZ ddlmZmZ d dd�Zd dd �Z d d d �Z d d d �Z d dd�Z d dd�Z d dd�Zd dd�Zd dd�Zd dd�ZdS )!a� General management and processing of queues. ============================================ This runner facilitates interacting with various queue backends such as the included sqlite3 queue or the planned AWS SQS and Redis queues The queue functions such as `insert`, `delete`, and `pop` can be used for typical management of the queue. The `process_queue` function pops the requested number of items from the queue and creates a Salt Event that can then be processed by a Reactor. The `process_queue` function can be called manually, or can be configured to run on a schedule with the Salt Scheduler or regular system cron. It is also possible to use the peer system to allow a minion to call the runner. This runner, as well as the Queues system, is not api stable at this time. There are many things that could potentially be done with queues within Salt. For the time being the focus will be on queueing infrastructure actions on specific minions. The queues generally will be populated with minion IDs. When the `process_queue` runner function is called events are created on the Salt Event bus that indicate the queue and a list of one or more minion IDs. The reactor is set up to match on event tags for a specific queue and then take infrastructure actions on those minion IDs. These actions might be to delete the minion's key from the master, use salt-cloud to destroy the vm, or some other custom action. Queued runners ============== Using the Salt Queues, references to the commandline arguments of other runners can be saved to be processed later. The queue runners require a queue backend that can store json data (default: :mod:`pgjsonb <salt.queues.pgjsonb_queue>`). Once the queue is setup, the `runner_queue` will need to be configured. .. code-block:: yaml runner_queue: queue: runners backend: pgjsonb .. note:: only the queue is required, this defaults to using pgjsonb Once this is set, then the following can be added to the scheduler on the master and it will run the specified amount of commands per time period. .. code-block:: yaml schedule: runner queue: schedule: function: queue.process_runner minutes: 1 kwargs: quantity: 2 The above configuration will pop 2 runner jobs off the runner queue, and then run them. And it will do this every minute, unless there are any jobs that are still running from the last time the process_runner task was executed. � N)�SaltInvocationError)� get_event�tagify�sqlitec C �@ t j�t�}d�|�}||vrtd�|���|| || d�}|S )aV Add an item or items to a queue CLI Example: .. code-block:: bash salt-run queue.insert myqueue myitem salt-run queue.insert myqueue "['item1', 'item2', 'item3']" salt-run queue.insert myqueue myitem backend=sqlite salt-run queue.insert myqueue "['item1', 'item2', 'item3']" backend=sqlite z {}.insert� Function "{}" is not available��items�queue��salt�loaderZqueues�__opts__�formatr �r r �backend� queue_funcs�cmd�ret� r �F/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/queue.py�insertF s r c C r )a Delete an item or items from a queue CLI Example: .. code-block:: bash salt-run queue.delete myqueue myitem salt-run queue.delete myqueue myitem backend=sqlite salt-run queue.delete myqueue "['item1', 'item2', 'item3']" z {}.deleter r r r r r r �delete[ s r c C s: t j�t�}d�| �}||vrtd�|���|| � }|S )z� Return a list of Salt Queues on the backend CLI Example: .. code-block:: bash salt-run queue.list_queues salt-run queue.list_queues backend=sqlite z{}.list_queuesr r )r r r r r r r � list_queueso s r c C �> t j�t�}d�|�}||vrtd�|���|| | d�}|S )z� Provide the number of items in a queue CLI Example: .. code-block:: bash salt-run queue.list_length myqueue salt-run queue.list_length myqueue backend=sqlite z{}.list_lengthr �r r �r r r r r r r r � list_length� � r c C r )z� List contents of a queue CLI Example: .. code-block:: bash salt-run queue.list_items myqueue salt-run queue.list_items myqueue backend=sqlite z {}.list_itemsr r r r r r r � list_items� r r � Fc C sB t j�t�}d�|�}||vrtd�|���|| || |d�}|S )a9 Pop one or more or all items from a queue CLI Example: .. code-block:: bash salt-run queue.pop myqueue salt-run queue.pop myqueue 6 salt-run queue.pop myqueue all salt-run queue.pop myqueue 6 backend=sqlite salt-run queue.pop myqueue all backend=sqlite z{}.popr )�quantityr � is_runnerr )r r! r r" r r r r r r �pop� s r# c C s� t dtd tdd��L}z t| |||d�}W n& ty; } zd�|�}t�d|id� W Y d }~W d � dS d }~ww ||| d �}|�|t| d gd d �� W d � |S 1 sYw Y |S )a4 Pop items off a queue and create an event on the Salt event bus to be processed by a Reactor. CLI Example: .. code-block:: bash salt-run queue.process_queue myqueue salt-run queue.process_queue myqueue 6 salt-run queue.process_queue myqueue all backend=sqlite ZmasterZsock_dirF)�opts�listen)r r! r r" z{}�errorsZprogressN)r r r �processr )�prefix)r r r# r r Z __jid_event__Z fire_eventr ) r r! r r" Z event_busr �excZ error_txt�datar r r � process_queue� s6 � � �� � ��r+ c C s@ | du r t �di ��d�} |du rt �di ��dd�}|| d�S )z4 Get consistent opts for the queued runners NZ runner_queuer r Zpgjsonb)r r )r �get�r r r r r �__get_queue_opts� s r. c C sX |du rg }n t |t�r|�d�}|du ri }t||d�}| ||d�}tdd|i|��S )aZ Insert a reference to a runner into the queue so that it can be run later. fun The runner function that is going to be run args list or comma-separated string of args to send to fun kwargs dictionary of keyword arguments to send to fun queue queue to insert the runner reference into backend backend that to use for the queue CLI Example: .. code-block:: bash salt-run queue.insert_runner test.stdout_print salt-run queue.insert_runner event.send test_insert_runner kwargs='{"data": {"foo": "bar"}}' N�,r- )�fun�args�kwargsr r )� isinstance�str�splitr. r )r0 r1 r2 r r � queue_kwargsr* r r r � insert_runner� s r7 c C sP t ||d�}td | dd�|��}|d D ]}t|d |d i |d �� qdS ) aC Process queued runners quantity number of runners to process queue queue to insert the runner reference into backend backend that to use for the queue CLI Example: .. code-block:: bash salt-run queue.process_runner salt-run queue.process_runner 5 r- T)r! r" r r0 r1 r2 Nr )r. r+ Z__salt__)r! r r r6 r* Zjobr r r �process_runner s �r8 )r )r r F)NN)NNNN)r NN)�__doc__Z salt.loaderr Zsalt.exceptionsr Zsalt.utils.eventr r r r r r r r# r+ r. r7 r8 r r r r �<module> s @ & &
Save