def write_batch_data(self, items):
dynamodb_conn = self.get_conn()<EOL>try:<EOL><INDENT>table = dynamodb_conn.Table(self.table_name)<EOL>with table.batch_writer(overwrite_by_pkeys=self.table_keys) as batch:<EOL><INDENT>for item in items:<EOL><INDENT>batch.put_item(Item=item)<EOL><DEDENT><DEDENT>return True<EOL><DEDENT>except Exception as general_error:<EOL><INDENT>raise AirflowException(<EOL>'<STR_LIT>'.format(<EOL>error=str(general_error)<EOL>)<EOL>)<EOL><DEDENT>
Write batch items to dynamodb table with provisioned throughout capacity.