Function build_data

src/ceph-node-proxy/ceph_node_proxy/redfish.py:234–265

(
    data: Dict[str, Any],
    fields: List[str],
    log: Any,
    attribute: Optional[str] = None,
)

def build_data(
    data: Dict[str, Any],
    fields: List[str],
    log: Any,
    attribute: Optional[str] = None,
) -> Dict[str, Dict[str, Dict]]:
    result: Dict[str, Dict[str, Optional[Dict]]] = dict()

    def process_data(m_id: str, flds: List[str], d: Dict[str, Any]) -> Dict[str, Any]:
        out: Dict[str, Any] = {}
        for field in flds:
            try:
                out[to_snake_case(field)] = d[field]
            except KeyError:
                log.debug(f"Could not find field: {field} in data: {d}")
                out[to_snake_case(field)] = None
        return out

    try:
        if attribute is not None:
            data_items = data[attribute]
        else:
            data_items = [{"MemberId": k, **v} for k, v in data.items()]
        log.debug(f"build_data: data_items count={len(data_items)}")
        for d in data_items:
            member_id = d.get("MemberId")
            result[member_id] = {}
            result[member_id] = process_data(member_id, fields, d)
    except (KeyError, TypeError, AttributeError) as e:
        log.error(f"Can't build data: {e}")
        raise
    return normalize_dict(result)


def _resolve_path(endpoint: Endpoint, path: str) -> Endpoint: