mirror of
https://github.com/valitydev/salt.git
synced 2024-11-08 01:18:58 +00:00
Merge pull request #9532 from s0undt3ch/develop
Mostly white-space lint fixes
This commit is contained in:
commit
b4a8edcc4c
@ -638,7 +638,7 @@ def destroy(name, call=None):
|
||||
'salt/cloud/{0}/destroying'.format(name),
|
||||
{'name': name},
|
||||
)
|
||||
|
||||
|
||||
scrub_data = config.get_cloud_config_value(
|
||||
'scrub_data', get_configured_provider(), __opts__, search_global=False, default=True
|
||||
)
|
||||
|
@ -1648,7 +1648,6 @@ def lstat(path):
|
||||
return {}
|
||||
|
||||
|
||||
|
||||
def access(path, mode):
|
||||
'''
|
||||
Test whether the Salt process has the specified access to the file. One of
|
||||
|
@ -14,10 +14,13 @@ Configuring the mysql ext_pillar
|
||||
- mysql:
|
||||
mysql_query: "SELECT pillar,value FROM pillars WHERE minion_id = %s"
|
||||
|
||||
You can basically use any SELECT query here that gets you the information, you could even do joins or subqueries in case your minion_id is stored elsewhere.
|
||||
The query should always return two pieces of information in the correct order: key, value. It is capable of handling single rows or multiple rows per minion.
|
||||
You can basically use any SELECT query here that gets you the information, you
|
||||
could even do joins or subqueries in case your minion_id is stored elsewhere.
|
||||
The query should always return two pieces of information in the correct order(
|
||||
key, value). It is capable of handling single rows or multiple rows per minion.
|
||||
|
||||
MySQL configuration of the MySQL returner is being used (mysql.db, mysql.user, mysql.pass, mysql.port, mysql.host)
|
||||
MySQL configuration of the MySQL returner is being used (mysql.db, mysql.user,
|
||||
mysql.pass, mysql.port, mysql.host)
|
||||
|
||||
Required python modules: MySQLdb
|
||||
'''
|
||||
@ -39,11 +42,13 @@ try:
|
||||
except ImportError:
|
||||
HAS_MYSQL = False
|
||||
|
||||
|
||||
def __virtual__():
|
||||
if not HAS_MYSQL:
|
||||
return False
|
||||
return False
|
||||
return 'mysql'
|
||||
|
||||
|
||||
def _get_options():
|
||||
'''
|
||||
Returns options used for the MySQL connection.
|
||||
@ -64,25 +69,30 @@ def _get_options():
|
||||
|
||||
return _options
|
||||
|
||||
|
||||
@contextmanager
|
||||
def _get_serv():
|
||||
'''
|
||||
Return a mysql cursor
|
||||
'''
|
||||
_options = _get_options()
|
||||
conn = MySQLdb.connect(host=_options['host'], user=_options['user'], passwd=_options['pass'], db=_options['db'], port=_options['port'])
|
||||
conn = MySQLdb.connect(host=_options['host'],
|
||||
user=_options['user'],
|
||||
passwd=_options['pass'],
|
||||
db=_options['db'], port=_options['port'])
|
||||
cursor = conn.cursor()
|
||||
try:
|
||||
yield cursor
|
||||
except MySQLdb.DatabaseError as err:
|
||||
log.exception('Error in ext_pillar MySQL: {0}'.format(err.args))
|
||||
log.exception('Error in ext_pillar MySQL: {0}'.format(err.args))
|
||||
finally:
|
||||
conn.close()
|
||||
conn.close()
|
||||
|
||||
def ext_pillar( minion_id, pillar, mysql_query, *args, **kwargs ):
|
||||
|
||||
def ext_pillar(minion_id, pillar, mysql_query, *args, **kwargs):
|
||||
'''
|
||||
Execute the query and return its data as a set
|
||||
'''
|
||||
'''
|
||||
log.info('Querying MySQL for information for {0}'.format(minion_id, ))
|
||||
#
|
||||
# this is pretty much WIP still, not sure whether this is a parameter that is being filled in at some point.
|
||||
@ -100,7 +110,7 @@ def ext_pillar( minion_id, pillar, mysql_query, *args, **kwargs ):
|
||||
|
||||
return_data = {}
|
||||
for ret in cur.fetchall():
|
||||
return_data[ ret[0] ] = ret[1]
|
||||
return_data[ret[0]] = ret[1]
|
||||
|
||||
log.debug('ext_pillar MySQL: Return data: {0}'.format(return_data))
|
||||
return return_data
|
||||
|
Loading…
Reference in New Issue
Block a user