File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/cassandra_cql.cpython-310.pyc
Back
o ;j�� � @ s� d Z ddlZddlZddlZddlZddlZddlmZ dZ e� e �Z dZ dZzPddlmZ ddlmZmZ dd lmZmZmZ dd lmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% dd l&m'Z' d Zee e"ee%e$e e#ee!e e e d � Z(W n e)y� Y nw dd� Z*dd� Z+dd� Z,d7dd�Z-dd� Z. d8dd�Z/ d8dd�Z0 d9d d �Z1 d8d d �Z2 d8d d!�Z3 d8d"d#�Z4 d:d$d%�Z5 d8d&d'�Z6 ( ) d;d*d+�Z7 d8d,d-�Z8 d8d.d/�Z9 d<d0d1�Z: 2 d=d3d4�Z; 2 d>d5d6�Z<dS )?a� Cassandra Database Module .. versionadded:: 2015.5.0 This module works with Cassandra v2 and v3 and hence generates queries based on the internal schema of said version. :depends: DataStax Python Driver for Apache Cassandra https://github.com/datastax/python-driver pip install cassandra-driver :referenced by: Salt's cassandra_cql returner :configuration: The Cassandra cluster members and connection port can either be specified in the master or minion config, the minion's pillar or be passed to the module. Example configuration in the config for a single node: .. code-block:: yaml cassandra: cluster: 192.168.50.10 port: 9000 Example configuration in the config for a cluster: .. code-block:: yaml cassandra: cluster: - 192.168.50.10 - 192.168.50.11 - 192.168.50.12 port: 9000 username: cas_admin .. versionchanged:: 2016.11.0 Added support for ``ssl_options`` and ``protocol_version``. Example configuration with `ssl options <http://datastax.github.io/python-driver/api/cassandra/cluster.html#cassandra.cluster.Cluster.ssl_options>`_: If ``ssl_options`` are present in cassandra config the cassandra_cql returner will use SSL. SSL isn't used if ``ssl_options`` isn't specified. .. code-block:: yaml cassandra: cluster: - 192.168.50.10 - 192.168.50.11 - 192.168.50.12 port: 9000 username: cas_admin ssl_options: ca_certs: /etc/ssl/certs/ca-bundle.trust.crt # SSL version should be one from the ssl module # This is an optional parameter ssl_version: PROTOCOL_TLSv1 Additionally you can also specify the ``protocol_version`` to `use <http://datastax.github.io/python-driver/api/cassandra/cluster.html#cassandra.cluster.Cluster.ssl_options>`_. .. code-block:: yaml cassandra: cluster: - 192.168.50.10 - 192.168.50.11 - 192.168.50.12 port: 9000 username: cas_admin # defaults to 4, if not set protocol_version: 3 Also all configuration could be passed directly to module as arguments. .. code-block:: bash salt minion1 cassandra_cql.info contact_points=delme-nextgen-01 port=9042 cql_user=cassandra cql_pass=cassandra protocol_version=4 salt minion1 cassandra_cql.info ssl_options='{"ca_certs": /path/to/-ca.crt}' We can also provide the load balancing policy as arguments .. code-block:: bash salt minion1 cassandra_cql.cql_query "alter user cassandra with password 'cassandra2' ;" contact_points=scylladb cql_user=user1 cql_pass=password port=9142 protocol_version=4 ssl_options='{"ca_certs": path-to-client-ca.crt}' load_balancing_policy=DCAwareRoundRobinPolicy load_balancing_policy_args='{"local_dc": "datacenter1"}' � N)�CommandExecutionError� ssl_versionZ cassandra_cqlF)�PlainTextAuthProvider)�Cluster�NoHostAvailable)�ConnectionException�ConnectionShutdown�OperationTimedOut) �DCAwareRoundRobinPolicy� ExponentialReconnectionPolicy� HostDistance�HostFilterPolicy�IdentityTranslator�LoadBalancingPolicy�NoSpeculativeExecutionPlan� NoSpeculativeExecutionPolicy� RetryPolicy�RoundRobinPolicy�SimpleConvictionPolicy�TokenAwarePolicy�WhiteListRoundRobinPolicy)� dict_factoryT) r r r r r r r r r r r r r c C s t rtS dS )z� Return virtual name of the module only if the python driver can be loaded. :return: The virtual name of the module. :rtype: str )Fz9Cannot load cassandra_cql module: python driver not found)� HAS_DRIVER�__virtualname__� r r �N/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/cassandra_cql.py� __virtual__� s r c C s t �d| � d S )Nz,Cassandra_cql asynchronous call returned: %s)�log�error)�errorsr r r �_async_log_errors� s r c K s, | t v rt �| �di |��S t�d| � dS )z8 Returns the Load Balancer Policy class by name z The policy %s is not availableNr )�LOAD_BALANCING_POLICY_MAP�getr r )�nameZ policy_argsr r r �_get_lbp_policy� s r$ c C s� | sIt �d� z td di d�}W n ty$ } zt �d|� � d}~ww |�|�}|sG|r9t �d||� |}|S t �d|� td |� d ���|S | S ) aB Load properties for the cassandra module from config or pillar. :param property_name: The property to load. :type property_name: str or list of str :param config_option: The name of the config option. :type config_option: str :param set_default: Should a default be set if not found in config. :type set_default: bool :param default: The default value to be set. :type default: str or int :return: The property fetched from the configuration or default. :rtype: str or list of str zINo property specified in function, trying to load from salt configuration� config.option� cassandra��defaultz2Failed to get cassandra config options. Reason: %sNz"Setting default Cassandra %s to %szGNo cassandra %s specified in the configuration or passed to the module.zERROR: Cassandra z cannot be empty.)r �debug�__salt__� BaseExceptionr r" r )� property_name� config_option� set_defaultr( �options�eZloaded_propertyr r r �_load_properties� s4 � �� �� �r1 c C s� t d di d��dd�} i }| r?| d |d< t| v r=| t �d�s4d�d d � tt�D ��}td �|���t t| t �|t< |S dS ) z� Parse out ssl_options for Cassandra cluster connection. Make sure that the ssl_version (if any specified) is valid. r% r& r' � ssl_optionsN�ca_certs� PROTOCOL_z, c S s g | ] }|� d �r|�qS )r4 )� startswith)�.0�xr r r � <listcomp>� s z!_get_ssl_opts.<locals>.<listcomp>z�Invalid protocol_version specified! Please make sure that the ssl protocol version is one from the SSL module. Valid options are {}) r* r" � SSL_VERSIONr5 �join�dir�sslr �format�getattr)Zsslopts�ssl_optsZ valid_optsr r r � _get_ssl_opts� s$ � ��r@ c C s t rdt v rdt v rt d t d fS | du r t| dd�} t| t�r#| n| �d�} |du r4t|ddd d �}|du r@t|d dd d �}|du rLt|d dd d �}|du rXt|dddd �}|du rdt|ddi d �}|du rpt|dddd �}|r{t|fi |��}nt|�}zbt||d�} |du r�t� } n|} | r�t| || | ||dd�} n t| || ||dd�} t dd�D ] } z| � � } W n t y� t � d| � | dkrȂ Y q�w | t d< | t d< i t d< t �d| � | | fW S ty� Y dS tttf�y } z t �d| � tt|���d}~ww ) a Connect to a Cassandra cluster. :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str or list of str :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The session and cluster objects. :rtype: cluster object, session object Z cassandra_cql_returner_clusterZ cassandra_cql_returner_sessionN�cluster)r, r- �,�portTiR# )r, r- r. r( �usernamer& �password�protocol_version� �load_balancing_policy_args�load_balancing_policyr )rD rE )rC � auth_providerr2 rF rI � compression)rC rJ rF rI rK � z+Cassandra cluster.connect timed out, try %s� �cassandra_cql_preparedz1Successfully connected to Cassandra cluster at %sz,Could not connect to Cassandra cluster at %s)� __context__r1 � isinstance�list�splitr$ r r@ r �range�connectr r �warningr) � TypeErrorr r r r r �str)�contact_pointsrC �cql_user�cql_passrF rI rH r2 Zlbp_policy_clsrJ r? rA Z recontimes�session�errr r r �_connect s� .������������� � � ���� ��r] c C s� zt ||||||||d�\} } W n ty t�d� � ty/ } zt�d| � � d} ~ ww t| _g } t| t�rmt ||||d�} t � d| �}|� � \}}}z| | } W n t yf | �|t| ��} Y nw t�d| � z| �| �}W n ty� } zt�d| | � d | � d | � �}t|��d} ~ ww |r�|D ]'}i }|�� D ]\}}t|t�s�t|tttf�s�t|�}|||< q�| �|� q�| S ) a� Run a query on a Cassandra cluster and return a dictionary. :param query: The query to execute. :type query: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param params: The parameters for the query, optional. :type params: str :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: A dictionary from the return values of the query :rtype: list[dict] CLI Example: .. code-block:: bash salt 'cassandra-server' cassandra_cql.cql_query "SELECT * FROM users_by_name WHERE first_name = 'jane'" �rX rC rY rZ rF rI rH r2 �(Could not get Cassandra cluster session.�<Unexpected error while getting Cassandra cluster session: %sN)rX rC rY rZ z^(\d+)\.(\d+)(?:\.(\d+))?zNew query is: %s�'Failed to execute query: %s reason: %s� ERROR: Cassandra query failed: � reason: )r] r r �criticalr+ r � row_factoryrP �dict�version�re�match�groups�KeyErrorr" �maxr) �executer �itemsrW �setrQ �append)�queryrX rC rY rZ rF rI rH r2 rA r[ r0 �retZcluster_versionri �major�minorZpoint�results�msg�result�values�key�valuer r r � cql_query� sl +� �� � � �� r{ c K s� d| v r | � dd�}zt||||d| | dd�\}}W n ty' t�d� � ty9 } zt�d|� � d}~ww |td vraz |�| �}|td |< W n ty` } zt�d|� � d}~ww td | }t|_ g }z|rx|� |� |��}n|� |� |��}W n ty� } zt� d | |� d | � d |� �}t|��d}~ww |s�|r�|D ]'}i }|�� D ]\}}t|t�s�t|tttf�s�t|�}|||< q�|�|� q�|S ) a� Run a query on a Cassandra cluster and return a dictionary. This function should not be used asynchronously for SELECTs -- it will not return anything and we don't currently have a mechanism for handling a future that will return results. :param query: The query to execute. :type query: str :param statement_name: Name to assign the prepared statement in the __context__ dictionary :type statement_name: str :param statement_arguments: Bind parameters for the SQL statement :type statement_arguments: list[str] :param asynchronous: Run this query in asynchronous mode :type asynchronous: bool :param async: Run this query in asynchronous mode (an alias to 'asynchronous') NOTE: currently it overrides 'asynchronous' and it will be dropped in version 3001! :type async: bool :param callback_errors: Function to call after query runs if there is an error :type callback_errors: Function callable :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param params: The parameters for the query, optional. :type params: str :param protocol_version: Cassandra protocol version to use. :type port: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: A dictionary from the return values of the query :rtype: list[dict] CLI Example: .. code-block:: bash # Insert data asynchronously salt this-node cassandra_cql.cql_query_with_prepare "name_insert" "INSERT INTO USERS (first_name, last_name) VALUES (?, ?)" statement_arguments=['John','Doe'], asynchronous=True # Select data, should not be asynchronous because there is not currently a facility to return data from a future salt this-node cassandra_cql.cql_query_with_prepare "name_select" "SELECT * FROM USERS WHERE first_name=?" statement_arguments=['John'] �asyncFNr^ r_ r` rN z2Unexpected error while preparing SQL statement: %sra rb rc )r" r] r r rd r+ rO Zpreparer re Z execute_async�bindrm r rn rP rW ro rQ rf rp )rq Zstatement_nameZstatement_argumentsZ asynchronousZcallback_errorsrX rC rY rZ rF rI rH r2 �kwargsrA r[ r0 Zbound_statementrr Zfuture_resultsru rv rw rx ry rz r r r �cql_query_with_prepare sp F � �� �� ���� r c C sp d}zt || |||||||d� } W n ty t�d� � ty0 } zt�d| � � d} ~ ww | d �d�S )a� Show the Cassandra version. :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The version for this Cassandra cluster. :rtype: str CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.version salt 'minion1' cassandra_cql.version contact_points=minion1 z1select release_version from system.local limit 1;r^ z Could not get Cassandra version.z4Unexpected error while getting Cassandra version: %sNr Zrelease_version)r{ r r rd r+ r" � rX rC rY rZ rF rI rH r2 rq rr r0 r r r rg � s, ( � ��rg c C �h d}i } zt || |||||||d� } W | S ty! t�d� � ty3 } zt�d| � � d} ~ ww )a� Show the Cassandra information for this cluster. :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The information for this Cassandra cluster. :rtype: dict CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.info salt 'minion1' cassandra_cql.info contact_points=minion1 af select cluster_name, data_center, partitioner, host_id, rack, release_version, cql_version, schema_version, thrift_version from system.local limit 1;r^ z Could not list Cassandra info.z1Unexpected error while listing Cassandra info: %sN�r{ r r rd r+ r� r r r �info� s. ) � � ��r� c C sn ddd�}i } zt || |||||||d� } W | S ty$ t�d� � ty6 } zt�d| � � d} ~ ww )a� List keyspaces in a Cassandra cluster. :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The keyspaces in this Cassandra cluster. :rtype: list[dict] CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.list_keyspaces salt 'minion1' cassandra_cql.list_keyspaces contact_points=minion1 port=9000 z2select keyspace_name from system.schema_keyspaces;z2select keyspace_name from system_schema.keyspaces;��2�3r^ zCould not list keyspaces.z,Unexpected error while listing keyspaces: %sNr� r� r r r �list_keyspaces( s2 )�� � ��r� c C s� | rd| � d�nd} d� | �d| � d�d�} i } zt| ||||||||d� } W | S ty5 t�d � � tyG } zt�d | � � d } ~ ww ) a� List column families in a Cassandra cluster for all keyspaces or just the provided one. :param keyspace: The keyspace to provide the column families for, optional. :type keyspace: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The column families in this Cassandra cluster. :rtype: list[dict] CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.list_column_families salt 'minion1' cassandra_cql.list_column_families contact_points=minion1 salt 'minion1' cassandra_cql.list_column_families keyspace=system zwhere keyspace_name = '�'� z>select columnfamily_name from system.schema_columnfamilies {};z.select column_name from system_schema.columns �;r� r^ z Could not list column families.z2Unexpected error while listing column families: %sN�r= r{ r r rd r+ ) �keyspacerX rC rY rZ rF rI rH r2 Z where_clauserq rr r0 r r r �list_column_familiesm s8 -� �� � ��r� c C s� d� | �d� | �d�} zt| ||||||||d� } W n ty' t�d� � ty9 } zt�d| � � d} ~ ww | r>dS d S ) a� Check if a keyspace exists in a Cassandra cluster. :param keyspace The keyspace name to check for. :type keyspace: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The info for the keyspace or False if it does not exist. :rtype: dict CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.keyspace_exists keyspace=system zMselect keyspace_name from system.schema_keyspaces where keyspace_name = '{}';zMselect keyspace_name from system_schema.keyspaces where keyspace_name = '{}';r� r^ z'Could not determine if keyspace exists.z9Unexpected error while determining if keyspace exists: %sNTFr� ) r� rX rC rY rZ rF rI rH r2 rq rr r0 r r r �keyspace_exists� s4 +� � �� r� �SimpleStrategyrL c C s t | |||||| | | d� } | s~d|i} |rDt|t�r;ztjj�|�}| jd i |�� W n ty: t � d� Y dS w | jd i |�� n|| d< d� | | �}zt ||||||| | | d� W d S t yk t �d� � ty} } zt �d |� � d }~ww d S ) az Create a new keyspace in Cassandra. :param keyspace: The keyspace name :type keyspace: str :param replication_strategy: either `SimpleStrategy` or `NetworkTopologyStrategy` :type replication_strategy: str :param replication_factor: number of replicas of data on multiple nodes. not used if using NetworkTopologyStrategy :type replication_factor: int :param replication_datacenters: string or dict of datacenter names to replication factors, required if using NetworkTopologyStrategy (will be a dict if coming from state file). :type replication_datacenters: str | dict[str, int] :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The info for the keyspace or False if it does not exist. :rtype: dict CLI Example: .. code-block:: bash # CLI Example: salt 'minion1' cassandra_cql.create_keyspace keyspace=newkeyspace salt 'minion1' cassandra_cql.create_keyspace keyspace=newkeyspace replication_strategy=NetworkTopologyStrategy replication_datacenters='{"datacenter_1": 3, "datacenter_2": 2}' �rX rY rZ rC rF rI rH r2 �classz,Could not load json replication_datacenters.F�replication_factorzCcreate keyspace {} with replication = {} and durable_writes = true;r^ zCould not create keyspace.z,Unexpected error while creating keyspace: %sNr )r� rP rW �salt�utils�json�loads�updater+ r r r= r{ r rd )r� Zreplication_strategyr� Zreplication_datacentersrX rC rY rZ rF rI rH r2 �existing_keyspaceZreplication_mapZreplication_datacenter_maprq r0 r r r �create_keyspace sd 7� � �� � ���r� c C s� t | ||||||||d� } | rEd| � d�} zt| ||||||||d� W dS ty2 t�d� � tyD } zt�d| � � d} ~ ww dS ) a> Drop a keyspace if it exists in a Cassandra cluster. :param keyspace: The keyspace to drop. :type keyspace: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The info for the keyspace or False if it does not exist. :rtype: dict CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.drop_keyspace keyspace=test salt 'minion1' cassandra_cql.drop_keyspace keyspace=test contact_points=minion1 r� zdrop keyspace r� r^ zCould not drop keyspace.z,Unexpected error while dropping keyspace: %sNT)r� r{ r r rd r+ ) r� rX rC rY rZ rF rI rH r2 r� rq r0 r r r � drop_keyspacer sF +� � � ��r� c C r� )a� List existing users in this Cassandra cluster. :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param port: The Cassandra cluster port, defaults to None. :type port: int :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: The list of existing users. :rtype: dict CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.list_users salt 'minion1' cassandra_cql.list_users contact_points=minion1 z list users;r^ zCould not list users.z(Unexpected error while listing users: %sNr� r� r r r � list_users� s. (� � ��r� c C s� |rdnd} d� | || �} t�d| | � zt| ||||||| | d� W d S ty1 t�d� � tyC } zt�d| � � d} ~ ww ) aG Create a new cassandra user with credentials and superuser status. :param username: The name of the new user. :type username: str :param password: The password of the new user. :type password: str :param superuser: Is the new user going to be a superuser? default: False :type superuser: bool :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: :rtype: CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.create_user username=joe password=secret salt 'minion1' cassandra_cql.create_user username=joe password=secret superuser=True salt 'minion1' cassandra_cql.create_user username=joe password=secret superuser=True contact_points=minion1 � superuserZ nosuperuserz3create user if not exists {} with password '{}' {};z=Attempting to create a new user with username=%s superuser=%sr^ zCould not create user.z(Unexpected error while creating user: %sNT)r= r r) r{ r rd r+ )rD rE r� rX rC rY rZ rF rI rH r2 Z superuser_cqlrq r0 r r r � create_user s< 3��� � ��r� r� c C s� |r |� d|� �nd} |r|� d�nd} d| � d| � �}| r%|� d| � �}t �d|� i }zt||||||| | | d � }W |S tyJ t �d � � ty\ } zt �d |� � d }~ww ) aE List permissions. :param username: The name of the user to list permissions for. :type username: str :param resource: The resource (keyspace or table), if None, permissions for all resources are listed. :type resource: str :param resource_type: The resource_type (keyspace or table), defaults to 'keyspace'. :type resource_type: str :param permission: A permission name (e.g. select), if None, all permissions are listed. :type permission: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: Dictionary of permissions. :rtype: dict CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.list_permissions salt 'minion1' cassandra_cql.list_permissions username=joe resource=test_keyspace permission=select salt 'minion1' cassandra_cql.list_permissions username=joe resource=test_table resource_type=table permission=select contact_points=minion1 � z all keyspacesz permissionzall permissionszlist z on z of z.Attempting to list permissions with query '%s'r^ zCould not list permissions.z.Unexpected error while listing permissions: %sN�r r) r{ r rd r+ )rD �resource� resource_type� permissionrX rC rY rZ rF rI rH r2 Z keyspace_cql�permission_cqlrq rr r0 r r r �list_permissionsW s8 7 � � ��r� c C s� |rd|� �nd} |rd|� d|� �nd} | � d| � d| � �}t �d|� zt||||||| | | d� W d S tyB t �d � � tyT } zt �d |� � d }~ww ) a Grant permissions to a user. :param username: The name of the user to grant permissions to. :type username: str :param resource: The resource (keyspace or table), if None, permissions for all resources are granted. :type resource: str :param resource_type: The resource_type (keyspace or table), defaults to 'keyspace'. :type resource_type: str :param permission: A permission name (e.g. select), if None, all permissions are granted. :type permission: str :param contact_points: The Cassandra cluster addresses, can either be a string or a list of IPs. :type contact_points: str | list[str] :param cql_user: The Cassandra user if authentication is turned on. :type cql_user: str :param cql_pass: The Cassandra user password if authentication is turned on. :type cql_pass: str :param port: The Cassandra cluster port, defaults to None. :type port: int :param protocol_version: Cassandra protocol version to use. :type protocol_version: int :param load_balancing_policy: cassandra.policy class name to use :type load_balancing_policy: str :param load_balancing_policy_args: cassandra.policy constructor args :type load_balancing_policy_args: dict :param ssl_options: Cassandra protocol version to use. :type ssl_options: dict :return: :rtype: CLI Example: .. code-block:: bash salt 'minion1' cassandra_cql.grant_permission salt 'minion1' cassandra_cql.grant_permission username=joe resource=test_keyspace permission=select salt 'minion1' cassandra_cql.grant_permission username=joe resource=test_table resource_type=table permission=select contact_points=minion1 zgrant zgrant all permissionszon r� zon all keyspacesz to z/Attempting to grant permissions with query '%s'r^ z Could not grant permissions.z/Unexpected error while granting permissions: %sNTr� )rD r� r� r� rX rC rY rZ rF rI rH r2 r� Z resource_cqlrq r0 r r r �grant_permission� s2 7 � � ��r� )FN)NNNNNNNN) FNNNNNNNNN) NNNNNNNNN) r� rL NNNNNNNNN) FNNNNNNNN) NNr� NNNNNNNNN) Nr� NNNNNNNNN)=�__doc__�loggingrh r< Zsalt.utils.jsonr� Zsalt.utils.versionsZsalt.exceptionsr r9 � getLogger�__name__r r r Zcassandra.authr Zcassandra.clusterr r Zcassandra.connectionr r r Zcassandra.policiesr r r r r r r r r r r r r Zcassandra.queryr r! � ImportErrorr r r$ r1 r@ r] r{ r rg r� r� r� r� r� r� r� r� r� r� r r r r �<module> sl _ < � � + � ( �q � �A �N �F �P �L �o �O �E �V �Z�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings