def __init__()

in kinesisresponder/kinesis_responder.py [0:0]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, role_name, session_name, stream_name, shard_id, aws_access_key_id=None, aws_secret_access_key=None, should_save=True, **kwargs):
        """
        Initialise
        :param role_name: ARN of role to assume
        :param session_name: Descriptive name for the role session
        :param stream_name: The name, not ARN, of the stream
        :param shard_id: Shard to connect to
        :param aws_access_key_id: access key to use in order to assume the role given by role_name
        :param aws_secret_access_key: secret key to use in order to assume the role given by role_name
        """
        super(KinesisResponder, self).__init__(**kwargs)
        self.role_name = role_name
        self.session_name = session_name
        self._conn = None
        self.stream_name = stream_name
        self.shard_id = shard_id
        self.should_save = should_save

        self._aws_access_key_id = aws_access_key_id
        self._aws_secret_access_key = aws_secret_access_key

        self._random = Random()
        self._random.seed()
        self.refresh_access_credentials()