Fetch a key value.
(bank, key)
| 282 | |
| 283 | |
| 284 | def fetch(bank, key): |
| 285 | """ |
| 286 | Fetch a key value. |
| 287 | """ |
| 288 | _init_client() |
| 289 | query = "SELECT data FROM {} WHERE bank=%s AND etcd_key=%s".format( |
| 290 | __context__["mysql_table_name"] |
| 291 | ) |
| 292 | cur, _ = run_query(__context__.get("mysql_client"), query, args=(bank, key)) |
| 293 | r = cur.fetchone() |
| 294 | cur.close() |
| 295 | if r is None: |
| 296 | return {} |
| 297 | return salt.payload.loads(r[0]) |
| 298 | |
| 299 | |
| 300 | def flush(bank, key=None): |