Pretty formatting of data structure dumps in log.

lakesuperior/endpoints/ldp.py

@@ -1,6 +1,7 @@
 import logging
 
 from collections import defaultdict
+from pprint import pformat
 from uuid import uuid4
 
 from flask import Blueprint, current_app, g, request, send_file, url_for
@@ -89,7 +90,7 @@ def get_resource(uuid, force_rdf=False):
     repr_options = defaultdict(dict)
     if 'prefer' in request.headers:
         prefer = Toolbox().parse_rfc7240(request.headers['prefer'])
-        logger.debug('Parsed Prefer header: {}'.format(prefer))
+        logger.debug('Parsed Prefer header: {}'.format(pformat(prefer)))
         if 'return' in prefer:
             repr_options = parse_repr_options(prefer['return'])
 
@@ -120,6 +121,7 @@ def post_resource(parent):
     out_headers = std_headers
     try:
         slug = request.headers['Slug']
+        logger.info('Slug: {}'.format(slug))
     except KeyError:
         slug = None
 
@@ -291,8 +293,7 @@ def uuid_for_post(parent_uuid=None, slug=None):
     if parent_uuid:
         parent_types = { t.identifier for t in \
                 parent.imr.objects(RDF.type) }
-        logger.debug('Parent types: {}'.format(
-                parent_types))
+        logger.debug('Parent types: {}'.format(pformat(parent_types)))
         if nsc['ldp'].Container not in parent_types:
             raise InvalidResourceError('Parent {} is not a container.'
                    .format(parent_uuid))
@@ -437,7 +438,7 @@ def parse_repr_options(retr_opts):
             if str(Ldpr.RETURN_SRV_MGD_RES_URI) in omit:
                     imr_options['incl_srv_mgd'] = False
 
-    logger.debug('Retrieval options: {}'.format(imr_options))
+    logger.debug('Retrieval options: {}'.format(pformat(imr_options)))
 
     return imr_options
 

lakesuperior/model/ldp_nr.py

@@ -88,7 +88,8 @@ class LdpNr(Ldpr):
 
         # File size.
         self._logger.debug('Data stream size: {}'.format(self.stream.limit))
-        self.provided_imr.set(nsc['premis'].hasSize, Literal(self.stream.limit))
+        self.provided_imr.set(nsc['premis'].hasSize,
+                Literal(self.stream.limit))
 
         # Checksum.
         cksum_term = URIRef('urn:sha1:{}'.format(self.digest))

lakesuperior/model/ldpr.py

@@ -4,6 +4,7 @@ from abc import ABCMeta
 from collections import defaultdict
 from copy import deepcopy
 from itertools import accumulate, groupby
+from pprint import pformat
 from uuid import uuid4
 
 import arrow
@@ -43,7 +44,7 @@ def atomic(fn):
             self._logger.info('Committing transaction.')
             self.rdfly.store.commit()
             for ev in request.changelog:
-                self._logger.info('Message: {}'.format(ev))
+                self._logger.info('Message: {}'.format(pformat(ev)))
                 self._send_event_msg(*ev)
             return ret
 
@@ -126,9 +127,9 @@ class Ldpr(metaclass=ABCMeta):
 
         @param uuid UUID of the instance.
         '''
+        cls._logger.info('Retrieving stored resource: {}'.format(uuid))
         imr_urn = nsc['fcres'][uuid] if uuid else cls.ROOT_NODE_URN
 
-        cls._logger.debug('Representation options: {}'.format(repr_opts))
         imr = current_app.rdfly.extract_imr(imr_urn, **repr_opts)
         rdf_types = set(imr.graph.objects(imr.identifier, RDF.type))
 

lakesuperior/store_layouts/ldp_rs/simple_layout.py

@@ -1,4 +1,5 @@
 from copy import deepcopy
+from pprint import pformat
 
 import arrow
 
@@ -111,8 +112,10 @@ class SimpleLayout(BaseRdfLayout):
         '''
         See base_rdf_layout.update_rsrc.
         '''
-        self._logger.debug('Remove triples: {}'.format(set(remove_trp)))
-        self._logger.debug('Add triples: {}'.format(set(add_trp)))
+        self._logger.debug('Remove triples: {}'.format(pformat(
+                set(remove_trp))))
+        self._logger.debug('Add triples: {}'.format(pformat(
+                set(add_trp))))
 
         for t in remove_trp:
             self.ds.remove(t)

tests/10K_children.py

@@ -1,9 +1,15 @@
 #!/usr/bin/env python
+import sys
 
 import arrow
 import requests
 
-n = 10000
+default_n = 10000
+
+sys.stdout.write('How many children? [{}] >'.format(default_n))
+choice = input().lower()
+
+n = choice or default_n
 
 # Generate 10,000 children of root node.