File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/solr.cpython-310.pyc
Back
o ;j�� � @ s\ d Z ddlZddlZddlZddlZdd� Zdd� Zdd� Z dEd d �Z dFd d �Z dGdd�Z dd� Z dHdd�ZdGdd�ZdFdd�Zdd� Zdd� ZdFd d �ZdHd d �ZdHd d!�ZdHd"d#�ZdFd$d%�ZdFd&d'�ZdFd(d)�ZdFd*d+�ZdFd,d-�ZdId/d0�Z dFd1d2�Z dFd3d4�Z dHd5d6�Z dFd7d8�Z dFd9d:�Z!dId;d<�Z"dId=d>�Z#dJd?d@�Z$dJdAdB�Z%dIdCdD�Z&dS )Ka� Apache Solr Salt Module Author: Jed Glazner Version: 0.2.1 Modified: 12/09/2011 This module uses HTTP requests to talk to the apache solr request handlers to gather information and report errors. Because of this the minion doesn't necessarily need to reside on the actual slave. However if you want to use the signal function the minion must reside on the physical solr host. This module supports multi-core and standard setups. Certain methods are master/slave specific. Make sure you set the solr.type. If you have questions or want a feature request please ask. Coming Features in 0.3 ---------------------- 1. Add command for checking for replication failures on slaves 2. Improve match_index_versions since it's pointless on busy solr masters 3. Add additional local fs checks for backups to make sure they succeeded Override these in the minion config ----------------------------------- solr.cores A list of core names e.g. ['core1','core2']. An empty list indicates non-multicore setup. solr.baseurl The root level URL to access solr via HTTP solr.request_timeout The number of seconds before timing out an HTTP/HTTPS/FTP request. If nothing is specified then the python global timeout setting is used. solr.type Possible values are 'master' or 'slave' solr.backup_path The path to store your backups. If you are using cores and you can specify to append the core name to the path in the backup method. solr.num_backups For versions of solr >= 3.5. Indicates the number of backups to keep. This option is ignored if your version is less. solr.init_script The full path to your init script with start/stop options solr.dih.options A list of options to pass to the DIH. Required Options for DIH ------------------------ clean : False Clear the index before importing commit : True Commit the documents to the index upon completion optimize : True Optimize the index after commit is complete verbose : True Get verbose output � Nc C s( t jj�d�r dS t jj�d�rdS dS )zZ PRIVATE METHOD Solr needs to be installed to use this. Return: str/bool Zsolrz apache-solr)FzfThe solr execution module failed to load: requires both the solr and apache-solr binaries in the path.)�salt�utils�path�which� r r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/solr.py� __virtual__F s r c C s6 | du rdS | s | S t | t�r| �� dkrdS | S dS )ag PRIVATE METHOD Checks to see if the value of a primitive or built-in container such as a list, dict, set, tuple etc is empty or none. None type is returned if the value is empty/None/False. Number data types that are 0 will return None. value : obj The primitive or built-in container to evaluate. Return: None or value N�none)� isinstance�str�lower)�valuer r r �_get_none_or_valueX s r c C s t td d��dkS )z� PRIVATE METHOD Checks to see if using_cores has been set or not. if it's been set return it, otherwise figure it out and set it. Then return it Return: boolean True if one or more cores defined in __opts__['solr.cores'] � config.option� solr.coresr )�len�__salt__r r r r �_check_for_coresr s r Tc C sB |du ri n|}|du rg n|}|du rg n|}| |||d�}|S )a PRIVATE METHOD Creates a new return dict with default values. Defaults may be overwritten. success : boolean (True) True indicates a successful result. data : dict<str,obj> ({}) Data to be returned to the caller. errors : list<str> ([()]) A list of error messages to be returned to the caller warnings : list<str> ([]) A list of warnings to be returned to the caller. Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} N)�success�data�errors�warningsr )r r r r �retr r r �_get_return_dict s r c C sZ |du rg n|}|du rg n|}|| d< | d � |� | d | | d< | d | | d< | S )a� PRIVATE METHOD Updates the return dictionary and returns it. ret : dict<str,obj> The original return dict to update. The ret param should have been created from _get_return_dict() success : boolean (True) True indicates a successful result. data : dict<str,obj> ({}) Data to be returned to the caller. errors : list<str> ([()]) A list of error messages to be returned to the caller warnings : list<str> ([]) A list of warnings to be returned to the caller. Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} Nr r r r )�update)r r r r r r r r �_update_return_dict� s r c C s� |du rg n|}t |�du s|dkrtd d�}td d�}td d�}t |�du rN|du s4t|�dkrBd|� d |� |� d | � d �S d �|||| d �|��S |du sXt|�dkrad�||||| �S d�||||| d �|��S )aR PRIVATE METHOD Formats the URL based on parameters, and if cores are used or not handler : str The request handler to hit. host : str (None) The solr host to query. __opts__['host'] is default core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. extra : list<str> ([]) A list of name value pairs in string format. e.g. ['name=value'] Return: str Fully formatted URL (http://<host>:<port>/solr/<handler>?wt=json&<extra>) N�Noner z solr.hostz solr.portz solr.baseurlr zhttp://�:�/z?wt=jsonz http://{}:{}{}/{}?wt=json&{}�&z http://{}:{}{}/{}/{}?wt=jsonz http://{}:{}{}/{}/{}?wt=json&{})r r r �format�join)�handler�host� core_name�extra�portZbaseurlr r r � _format_url� s$ � ��r' c C s� t d dd�}t d dd�}t d dd�}|rB|rDtj�� }|j|| ||d� tj�� }|j|| ||d� tj�tj�||�� dS dS dS ) z- Install an auth handler for urllib2 z config.getz solr.userFz solr.passwdzsolr.auth_realmZSolr)�realmZuri�user�passwdN)r �urllib�requestZHTTPBasicAuthHandlerZ add_passwordZHTTPDigestAuthHandlerZinstall_openerZ build_opener)�urlr) �passwordr( Zbasic�digestr r r �_auth� s �r0 c C s� t | � z&td d�}|du ri nd|i}tjj�tjj| fi |���}t d|g �W S t yH } zt di | � d|� �g�W Y d}~S d}~ww )a� PRIVATE METHOD Uses salt.utils.json.load to fetch the JSON results from the solr API. url : str a complete URL that can be passed to urllib.open request_timeout : int (None) The number of seconds before the timeout should fail. Leave blank/None to use the default. __opts__['solr.request_timeout'] Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} r zsolr.request_timeoutN�timeoutTFz : ) r0 r r r �json�loadr+ r, �urlopenr � Exception)r- Zrequest_timeout�kwargsr �errr r r � _http_request� s $��r8 c C s8 |du rg n|}d| � �g| }t d|||d�}t|�S )a� PRIVATE METHOD Performs the requested replication command and returns a dictionary with success, errors and data as keys. The data object will contain the JSON response. command : str The replication command to execute. host : str (None) The solr host to query. __opts__['host'] is default core_name: str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. params : list<str> ([]) Any additional parameters you want to send. Should be a lsit of strings in name=value format. e.g. ['name=value'] Return: dict<str, obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} Nzcommand=Z replication�r# r$ r% �r' r8 )�commandr# r$ �paramsr% r- r r r �_replication_request s r= c C s t d| � �||d�}t|�}|S )a� PRIVATE METHOD Calls the _http_request method and passes the admin command to execute and stores the data. This data is fairly static but should be refreshed periodically to make sure everything this OK. The data object will contain the JSON response. command : str The admin command to execute. host : str (None) The solr host to query. __opts__['host'] is default core_name: str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} zadmin/�r$ r: )r; r# r$ r- �respr r r �_get_admin_info& s r@ c C s t d d�dkS )z� PRIVATE METHOD Simple method to determine if the minion is configured as master or slave Return: boolean:: True if __opts__['solr.type'] = master r z solr.type�master)r r r r r � _is_master? s rB c C sP t d d�}t| t�r|�| � |�� D ]\}}t|t�r%t|��� ||< q|S )a� PRIVATE METHOD updates the default import options from __opts__['solr.dih.import_options'] with the dictionary passed in. Also converts booleans to strings to pass to solr. options : dict<str,boolean> Dictionary the over rides the default options defined in __opts__['solr.dih.import_options'] Return: dict<str,boolean>:: {option:boolean} r zsolr.dih.import_options)r r �dictr �items�boolr r )�options�defaults�key�valr r r �_merge_optionsK s �rJ c C s� t |�du rt� sdg}td|�S t |�du r#t� r#dg}td|d�S t| ||�}|d rV|d d }|d kr@d g}td |d �S |d krTd|� d�g}td|d |d�S |S d|� �g}td|d |d�S )a� PRIVATE METHOD - MASTER CALL Does a pre-check to make sure that all the options are set and that we can talk to solr before trying to send a command to solr. This Command should only be issued to masters. handler : str The import handler to check the state of host : str (None): The solr host to query. __opts__['host'] is default core_name (None): The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. REQUIRED if you are using cores. Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} N�>solr.pre_indexing_check can only be called by "master" minionsFz9solr.full_import is not safe to multiple handlers at once�r r r �statusZbusyz'An indexing process is already running.T)r ZidlezUnknown status: "�")r r z'Status check failed. Response details: )r rB r r � import_status)r" r# r$ r7 r r? rM �warnr r r �_pre_index_checkc s$ �rQ c C s� |du r|}n|� d|� �}g }| � � D ]3\}}||kr#|�||i� t|t�r:|D ]}t|t�r9|t|||� }q*t|t�rG|t|||� }q|S )a� PRIVATE METHOD Traverses a dictionary of dictionaries/lists to find key and return the value stored. TODO:// this method doesn't really work very well, and it's not really very useful in its current state. The purpose for this method is to simplify parsing the JSON output so you can just pass the key you want to find and have it return the value. ret : dict<str,obj> The dictionary to search through. Typically this will be a dict returned from solr. key : str The key (str) to find in the dictionary Return: list<dict<str,obj>>:: [{path:path, value:value}] Nr )rD �appendr �listrC � _find_value)Zret_dictrH r r ZikeyrI �itemr r r rT � s � �rT c C s� t � }t| �du rCt� rCd}td d�D ],}td|d�}|d r/|d d d }|d |ii}n|d dii}d }t||||d �}q|S td| d�}|d r_|d d d }t dd|i|d �S |S )a? Gets the lucene version that solr is using. If you are running a multi-core setup you should specify a core name since all the cores run under the same servlet container, they will all have the same version. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return: dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.lucene_version NTr r �systemr> r r �lucenezlucene-spec-version�lucene_versionFr �version)r r r r r@ r )r$ r r �namer? � version_numr r r r rX � s" rX c C s� t � }t| �du rDt� rDd}td D ]/}td|d�}|d r-|d d }|d |d ii}nd }|d dii}t||||d |d �}q|S td| d�}|d rc|d d d }t dd |i|d |d �S |S )a Gets the solr version for the core specified. You should specify a core here as all the cores will run under the same servlet container and so will all have the same version. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.version NTr rV r> r r rW rY zsolr-spec-versionFr r �r r r �__opts__r@ r )r$ r r rZ r? rW r r[ r r r rY � s* � �rY c C s� t � }t|�du rUt� rUd}td d�D ]>}td| |dgd�}t|�}|d r<|d |d ii}t||||d |d �}qd }|d |d ii}t||||d |d �}q|S td| |dgd�}t|�S ) a� Search queries fast, but it is a very expensive operation. The ideal process is to run this with a master/slave configuration. Then you can optimize the master, and push the optimized index to the slaves. If you are running a single solr instance, or if you are going to run this on a slave be aware than search performance will be horrible while this command is being run. Additionally it can take a LONG time to run and your HTTP request may timeout. If that happens adjust your timeout settings. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.optimize music NTr r r z optimize=truer9 r r r r F)r r r r r' r8 r )r# r$ r r rZ r- r? r r r r �optimize s. ��� �r^ c C s� t � }t|�du r>t� r>d}td D ])}td| |d�}|d r*|d|d d ii}nd }|ddii}t||||d �}q|S td| |d�}|S ) a� Does a health check on solr, makes sure solr can talk to the indexes. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.ping music NTr �ping�r# r$ r rM r Fr r\ �r# r$ r r rZ r? r r r r r_ K s r_ c s� t � }d}t� r| du rdg}|�d|d��S � fdd�}t|�du r?t� r?td D ]}td | |d �� |||� |�\}}q*|S td | |d �� |||� |�\}}|S ) a SLAVE CALL Check for errors, and determine if a slave is replicating or not. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.is_replication_enabled music TNz5Only "slave" minions can run "is_replication_enabled"F�r r c s� � d re|d d d }d}|d }d|v r5d}d � ||d |�}|d �|� |d u r.|n|d|ii}n|d d d }|dkrJ|d �d� d}|d dkrYd}|d �d� t| |||d |d �} | |fS )Nr r �details�slave�false� masterUrl�ERRORFz {}: {} - {}r � masterDetailsrA ZreplicationEnabledr z"Replication is disabled on master.ZisPollingDisabled�true�warningzPolling is disabled)r rR r ) r r r? �corerd �enabled� master_urlr7 r ��responser r �_checks� s( �z'is_replication_enabled.<locals>._checksr rc r` )r rB r r r r] r= )r# r$ r r r rp rZ r rn r �is_replication_enabledp s �rq c s� t � }d}t� rt| �du r|�ddgd��S � fdd�}t|�du rAt� rAd}td D ]}td | |d �� |||� |�\}}q,|S td | |d �� |||� |�\}}|S ) a5 SLAVE CALL Verifies that the master and the slave versions are in sync by comparing the index version. If you are constantly pushing updates the index the master and slave versions will seldom match. A solution to this is pause indexing every so often to allow the slave to replicate and then call this method before allowing indexing to resume. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.match_index_versions music TNFz?solr.match_index_versions can only be called by "slave" minionsrb c sF � d r�|d d d }|d d d d }d|v r>|d }d}|� d|� d |� �}|d � |� |d u r7|n|d|ii}n?|d d d |d d d |d g d�} d|v r`| �d|d i� | d | d krqd}|d � d� |d u rw| n|d| ii}t| |||d |d �} | |fS d}|d }|d }t| |||d�} | |fS )Nr r rc rd rf rg Fz: z - r rh rA ZreplicatableIndexVersionZ indexVersionZnextExecutionAt)rA rd Znext_replication� failed_listZreplicationFailedAtListrr z-Master and Slave index versions do not match.r rL )rR r r ) r r r? rk rd rm �errorr7 r Zversionsrn r r �_match� sB �����z$match_index_versions.<locals>._matchr rc r` )r rB r r r r] r= )r# r$ r r rt rZ r rn r �match_index_versions� s& ��� ) �ru c C s� t � }t|�du r/d}td D ] }td| |d�}|d|d ii}t||||d |d �}q|S td| |d�}|d rLt||d |d |d |d �}|S |S ) a� Get the full replication details. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.replication_details music NTr rc r` r r r r )r r r] r= r ra r r r �replication_details s" � ���rv Fc C s8 t d }t d }|dur|�tjj�s|tjj7 }t� }t|�du rrt� rrd}t d D ]D}g }|durE|r9|| n|}|�d|| � �� |�d|� �� t d| ||d �} | d s[d }|d | d ii} t ||| | d | d �}q+|S |dur�|dur�|r�||7 }|dur�d|� �g}|�d|� �� t d| ||d �} | S )aP Tell solr make a backup. This method can be mis-leading since it uses the backup API. If an error happens during the backup you are not notified. The status: 'OK' in the response simply means that solr received the request successfully. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. append_core_to_path : boolean (False) If True add the name of the core to the backup path. Assumes that minion backup path is not None. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.backup music zsolr.backup_pathzsolr.num_backupsNTr z &location=z&numberToKeep=�backup)r# r$ r< r Fr r r z location=) r] �endswith�osr �sepr r r rR r= r ) r# r$ Zappend_core_to_pathr Z num_backupsr r rZ r< r? r r r r rw < sD �� �rw c C s� t � }t� rt|�du rdg}|�d|d��S | rdnd}t|�du rRt� rRd}td D ]#}t|||d �}|d s;d}|d |d ii} t||| |d |d �}q,|S t|||d �}|S )aW SLAVE CALL Prevent the slaves from polling the master for updates. polling : boolean True will enable polling. False will disable it. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to check all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.set_is_polling False Nz9solr.set_is_polling can only be called by "slave" minionsFrb Z enablepollZ disapblepollTr r` r r r r ) r rB r r r r] �set_is_pollingr r= ) Zpollingr# r$ r r7 �cmdr rZ r? r r r r r{ | s$ �r{ c C s� t � st|�du rtddgd�S | rdnd}t|�du rMt� rMt� }d}td D ]"}t| ||�}|d s6d}|d |d ii}t||||d |d �}q(|S | rVt|||d �S t|||d �S )a� MASTER ONLY Sets the master to ignore poll requests from the slaves. Useful when you don't want the slaves replicating during indexing or when clearing the index. status : boolean Sets the replication status to the specified state. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str (None) The name of the solr core if using cores. Leave this blank if you are not using cores or if you want to set the status on all cores. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.set_replication_enabled false, None, music NFz.Only minions configured as master can run thisrL ZenablereplicationZdisablereplicationTr r r r r r` )rB r r r r] �set_replication_enabledr r= ) rM r# r$ r| r r rZ r? r r r r r} � s( � �r} c C sP d}| |vrd� | d�|dd� �|d �S d� td | �}td |d d � dS ) a� Signals Apache Solr to start, stop, or restart. Obviously this is only going to work if the minion resides on the solr host. Additionally Solr doesn't ship with an init script so one must be created. signal : str (None) The command to pass to the apache solr init valid values are 'start', 'stop', and 'restart' CLI Example: .. code-block:: bash salt '*' solr.signal restart )�start�stopZrestartz.{} is an invalid signal. Try: one of: {} or {}z, N���z{} {}zsolr.init_scriptzcmd.runF)Z python_shell)r r! r] r )�signal� valid_signalsr| r r r r� � s �r� c C � t � }t� sdg}|�d|d��S t|�du rDt� rDd}td D ]!}t| |�}|d s-d}|d|d ii}t||||d |d �}q |S d d |� �g}td | d|d�} t| �S )a� MULTI-CORE HOSTS ONLY Load a new core from the same configuration as an existing registered core. While the "new" core is initializing, the "old" one will continue to accept requests. Once it has finished, all new request will go to the "new" core, and the "old" core will be unloaded. host : str (None) The solr host to query. __opts__['host'] is default. core_name : str The name of the core to reload Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.reload_core None music Return data is in the following format:: {'success':bool, 'data':dict, 'errors':list, 'warnings':list} �;solr.reload_core can only be called by "multi-core" minionsFrb NTr r r r r z action=RELOAD�core=� admin/coresr9 � r r r r r] � reload_corer r' r8 � r# r$ r r7 r rZ r? r r% r- r r r r� � s$ �r� c C r� )a� MULTI-CORE HOSTS ONLY Get the status for a given core or all cores if no core is specified host : str (None) The solr host to query. __opts__['host'] is default. core_name : str The name of the core to reload Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.core_status None music r� Frb NTr r r r r z action=STATUSr� r� r9 r� r� r r r � core_status* s$ �r� c C sp t � st|�du rdg}td|�S t|�du r"t� r"dg}td|�S dg}|r,|�d� t| |||d�}t|�S )a� MASTER ONLY re-loads the handler config XML file. This command can only be run if the minion is a 'master' type handler : str The name of the data import handler. host : str (None) The solr host to query. __opts__['host'] is default. core : str (None) The core the handler belongs to. verbose : boolean (False) Run the command with verbose output. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.reload_import_config dataimport None music {'clean':True} NrK F�<No core specified when minion is configured as "multi-core".zcommand=reload-config� verbose=truer9 �rB r r r rR r' r8 �r" r# r$ �verboser7 r< r- r r r �reload_import_configV s r� c C sr t � st|�du rdg}td|d�S t|�du r#t� r#dg}td|�S dg}|r-|�d� t| |||d�}t|�S ) a� MASTER ONLY Aborts an existing import command to the specified handler. This command can only be run if the minion is configured with solr.type=master handler : str The name of the data import handler. host : str (None) The solr host to query. __opts__['host'] is default. core : str (None) The core the handler belongs to. verbose : boolean (False) Run the command with verbose output. Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.abort_import dataimport None music {'clean':True} Nz8solr.abort_import can only be called on "master" minionsFrL r� z command=abortr� r9 r� r� r r r � abort_import� s r� c C s� |du ri n|}|du rg n|}t � s dg}td|d�S t|�du r-t� r-dg}td|�S t| ||�}|d s9|S t|�}|d rUtd||d�}|d sUd g}td|d�S d g}|�� D ]\} } |�d | � d | � �� q\t | |||| d �} t | �S )a� MASTER ONLY Submits an import command to the specified handler using specified options. This command can only be run if the minion is configured with solr.type=master handler : str The name of the data import handler. host : str (None) The solr host to query. __opts__['host'] is default. core : str (None) The core the handler belongs to. options : dict (__opts__) A list of options such as clean, optimize commit, verbose, and pause_replication. leave blank to use __opts__ defaults. options will be merged with __opts__ extra : dict ([]) Extra name value pairs to pass to the handler. e.g. ["name=value"] Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.full_import dataimport None music {'clean':True} Nz7solr.full_import can only be called on "master" minionsFrL r� r �cleanr` �3Failed to set the replication status on the master.zcommand=full-importr �=r9 ) rB r r r rQ rJ r} rD rR r' r8 � r" r# r$ rF r% r7 r? r r< rH rI r- r r r � full_import� s, r� c C s� |du ri n|}|du rg n|}t � s"t|�du r"dg}td|d�S t| ||d�}|d s/|S t|�}|d rNt� rNtd||d�}|d sNdg}td|d�S d g}|�� D ]\} } |�| � d | � �� qUt | |||| d �} t | �S ) a� Submits an import command to the specified handler using specified options. This command can only be run if the minion is configured with solr.type=master handler : str The name of the data import handler. host : str (None) The solr host to query. __opts__['host'] is default. core : str (None) The core the handler belongs to. options : dict (__opts__) A list of options such as clean, optimize commit, verbose, and pause_replication. leave blank to use __opts__ defaults. options will be merged with __opts__ extra : dict ([]) Extra name value pairs to pass to the handler. e.g. ["name=value"] Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.delta_import dataimport None music {'clean':True} Nz8solr.delta_import can only be called on "master" minionsFrL r` r r� r� zcommand=delta-importr� r9 ) rB r r rQ rJ r r} rD rR r' r8 r� r r r � delta_import� s& r� c C sP t � st|�du rdg}td|d�S dg}|r |�d� t| |||d�}t|�S )a� Submits an import command to the specified handler using specified options. This command can only be run if the minion is configured with solr.type: 'master' handler : str The name of the data import handler. host : str (None) The solr host to query. __opts__['host'] is default. core : str (None) The core the handler belongs to. verbose : boolean (False) Specifies verbose output Return : dict<str,obj>:: {'success':boolean, 'data':dict, 'errors':list, 'warnings':list} CLI Example: .. code-block:: bash salt '*' solr.import_status dataimport None music False Nz9solr.import_status can only be called by "master" minionsFrL zcommand=statusr� r9 )rB r r rR r' r8 )r" r# r$ r� r r% r- r r r rO s rO )TNNN)NN)NNN)N)NNF)NNNN)'�__doc__ry �urllib.requestr+ Zsalt.utils.jsonr Zsalt.utils.pathr r r r r r' r0 r8 r= r@ rB rJ rQ rT rX rY r^ r_ rq ru rv rw r{ r} r� r� r� r� r� r� r� rO r r r r �<module> sJ < ) / ( + / 7 % H \ ( @ / 2 0 , * ) 85
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings