LSST Applications g0f08755f38+82efc23009,g12f32b3c4e+e7bdf1200e,g1653933729+a8ce1bb630,g1a0ca8cf93+50eff2b06f,g28da252d5a+52db39f6a5,g2bbee38e9b+37c5a29d61,g2bc492864f+37c5a29d61,g2cdde0e794+c05ff076ad,g3156d2b45e+41e33cbcdc,g347aa1857d+37c5a29d61,g35bb328faa+a8ce1bb630,g3a166c0a6a+37c5a29d61,g3e281a1b8c+fb992f5633,g414038480c+7f03dfc1b0,g41af890bb2+11b950c980,g5fbc88fb19+17cd334064,g6b1c1869cb+12dd639c9a,g781aacb6e4+a8ce1bb630,g80478fca09+72e9651da0,g82479be7b0+04c31367b4,g858d7b2824+82efc23009,g9125e01d80+a8ce1bb630,g9726552aa6+8047e3811d,ga5288a1d22+e532dc0a0b,gae0086650b+a8ce1bb630,gb58c049af0+d64f4d3760,gc28159a63d+37c5a29d61,gcf0d15dbbd+2acd6d4d48,gd7358e8bfb+778a810b6e,gda3e153d99+82efc23009,gda6a2b7d83+2acd6d4d48,gdaeeff99f8+1711a396fd,ge2409df99d+6b12de1076,ge79ae78c31+37c5a29d61,gf0baf85859+d0a5978c5a,gf3967379c6+4954f8c433,gfb92a5be7c+82efc23009,gfec2e1e490+2aaed99252,w.2024.46
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)