Source code for google.appengine.ext.bulkload.simpletext_connector

#!/usr/bin/env python
#
# Copyright 2007 Google Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#





"""Bulkloader Simple Text writing.

Handle the simpletext format specified in a bulkloader.yaml file.
"""











from google.appengine.ext.bulkload import bulkloader_errors
from google.appengine.ext.bulkload import connector_interface


[docs]class SimpleTextConnector(connector_interface.ConnectorInterface):
  """Write a text file from dicts for each record. Does not support import."""

  VALID_MODES = ('text', 'nonewline', 'binary')

[docs]  @classmethod
  def create_from_options(cls, options, name):
    """Factory using an options dictionary.

    Args:
      options: Dictionary of options containing:
        template: A Python dict-interpolation string. Required.
        prolog: written before the per-record output.
        epilog: written after the per-record output.
        mode: one of the following, default is 'text'
          text: text file mode, newlines between records.
          nonewline: text file mode, no added newlines.
          binary: binary file mode, no added newlines.
      name: The name of this transformer, for use in error messages.

    Returns:
      SimpleTextConnector object described by the specified options.

    Raises:
      InvalidConfiguration: If the config is invalid.
    """
    template = options.get('template')
    if not template:
      raise bulkloader_errors.InvalidConfiguration(
          'simpletext must specify template. (In transformer named %s)' % name)

    prolog = options.get('prolog')
    epilog = options.get('epilog')
    mode = options.get('mode', 'text')
    return cls(template, prolog, epilog, mode, name)

  def __init__(self, template, prolog=None, epilog=None, mode='text', name=''):
    """Constructor.

    Args:
      template: A Python dict-interpolation string.
      prolog: written before the per-record output.
      epilog: written after the per-record output.
      mode: one of the following, default is 'text'
        text: text file mode, newlines between records.
        nonewline: text file mode, no added newlines.
        binary: binary file mode, no added newlines.
    """
    if mode not in self.VALID_MODES:
      raise bulkloader_errors.InvalidConfiguration(
          'simpletext mode must be one of "%s". (In transformer name %s.)' %
          ('", "'.join(self.VALID_MODES), name))
    self.template = template
    self.prolog = prolog
    self.epilog = epilog
    self.mode = mode
    self.export_file_pointer = None

[docs]  def initialize_export(self, filename, bulkload_state):
    """Open file and write prolog."""
    self.bulkload_state = bulkload_state
    mode = 'w'
    if self.mode == 'binary':
      mode = 'wb'
    self.export_file_pointer = open(filename, mode)
    if self.prolog:
      self.export_file_pointer.write(self.prolog)
      if self.mode == 'text':
        self.export_file_pointer.write('\n')

[docs]  def write_dict(self, dictionary):
    """Write one record for the specified entity."""
    self.export_file_pointer.write(self.template % dictionary)
    if self.mode == 'text':
      self.export_file_pointer.write('\n')

[docs]  def finalize_export(self):
    """Write epliog and close file after every record is written."""
    if self.epilog:
      self.export_file_pointer.write(self.epilog)
      if self.mode == 'text':
        self.export_file_pointer.write('\n')
    self.export_file_pointer.close()