LSST Applications g0f08755f38+c89d42e150,g1635faa6d4+b6cf076a36,g1653933729+a8ce1bb630,g1a0ca8cf93+4c08b13bf7,g28da252d5a+f33f8200ef,g29321ee8c0+0187be18b1,g2bbee38e9b+9634bc57db,g2bc492864f+9634bc57db,g2cdde0e794+c2c89b37c4,g3156d2b45e+41e33cbcdc,g347aa1857d+9634bc57db,g35bb328faa+a8ce1bb630,g3a166c0a6a+9634bc57db,g3e281a1b8c+9f2c4e2fc3,g414038480c+077ccc18e7,g41af890bb2+e740673f1a,g5fbc88fb19+17cd334064,g7642f7d749+c89d42e150,g781aacb6e4+a8ce1bb630,g80478fca09+f8b2ab54e1,g82479be7b0+e2bd23ab8b,g858d7b2824+c89d42e150,g9125e01d80+a8ce1bb630,g9726552aa6+10f999ec6a,ga5288a1d22+065360aec4,gacf8899fa4+9553554aa7,gae0086650b+a8ce1bb630,gb58c049af0+d64f4d3760,gbd46683f8f+ac57cbb13d,gc28159a63d+9634bc57db,gcf0d15dbbd+e37acf7834,gda3e153d99+c89d42e150,gda6a2b7d83+e37acf7834,gdaeeff99f8+1711a396fd,ge2409df99d+cb1e6652d6,ge79ae78c31+9634bc57db,gf0baf85859+147a0692ba,gf3967379c6+02b11634a5,w.2024.45
LSST Data Management Base Package
Loading...
Searching...
No Matches
list_cassandra.py
Go to the documentation of this file.
1# This file is part of dax_apdb
2#
3# Developed for the LSST Data Management System.
4# This product includes software developed by the LSST Project
5# (https://www.lsst.org).
6# See the COPYRIGHT file at the top-level directory of this distribution
7# for details of code ownership.
8#
9# This program is free software: you can redistribute it and/or modify
10# it under the terms of the GNU General Public License as published by
11# the Free Software Foundation, either version 3 of the License, or
12# (at your option) any later version.
13#
14# This program is distributed in the hope that it will be useful,
15# but WITHOUT ANY WARRANTY; without even the implied warranty of
16# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17# GNU General Public License for more details.
18#
19# You should have received a copy of the GNU General Public License
20# along with this program. If not, see <https://www.gnu.org/licenses/>.
21
22from __future__ import annotations
23
24__all__ = ["list_cassandra"]
25
26from astropy.table import Table
27
28from ..cassandra import ApdbCassandra
29
30
31def list_cassandra(host: str, verbose: bool) -> None:
32 """List APDB instances in Cassandra cluster.
33
34 Parameters
35 ----------
36 host : `str`
37 Name of one of the hosts in Cassandra cluster.
38 verbose : `bool`
39 If `True` provide detailed output.
40 """
41 databases = ApdbCassandra.list_databases(host=host)
42 if databases:
43 if verbose:
44 table = Table(names=["Keyspace", "Role", "Permissions"], dtype=[str, str, str])
45 for database in databases:
46 if database.permissions is None:
47 # Can't access auth info.
48 table.add_row([database.name, "N/A", ""])
49 elif database.permissions:
50 for role, perm_list in database.permissions.items():
51 permissions = ", ".join(sorted(perm_list))
52 table.add_row([database.name, role, permissions])
53 else:
54 # Anonymous access should have all permissions, do not
55 # list any specific permissions for that. Anon access
56 # should not be enabled in production.
57 table.add_row([database.name, "anonymous", ""])
58 table.sort(["Keyspace", "Role"])
59 else:
60 table = Table(names=["Keyspace", "Roles[access]"], dtype=[str, str])
61 for database in databases:
62 if database.permissions is None:
63 # Can't access auth info.
64 table.add_row([database.name, "N/A"])
65 elif database.permissions:
66 roles = []
67 for role, perm_list in database.permissions.items():
68 access = _access(perm_list)
69 roles.append(f"{role}[{access}]")
70 table.add_row([database.name, ", ".join(sorted(roles))])
71 else:
72 table.add_row([database.name, "anonymous"])
73 table.sort("Keyspace")
74
75 table.pprint_all(align="<")
76
77
78def _access(permissions: set[str]) -> str:
79 """Convert list of Cassandra permissions into access mode string"""
80 if {"CREATE", "DROP"} & permissions:
81 return "manage"
82 elif "MODIFY" in permissions:
83 return "update"
84 elif "SELECT" in permissions:
85 return "read"
86 else:
87 return "none"
Tag types used to declare specialized field types.
Definition misc.h:31
str _access(set[str] permissions)