Executes streaming ingest against this client.
        :param str database: Target database.
        :param str table: Target table.
        :param io.BaseIO stream: stream object which contains the data to ingest.
        :param DataFormat stream_format: Format of the data in the stream.
        :param str mapping_name: Pre-defined mapping of the table. Required when stream_format is json/avro.
        Other optional params: optional request headers as documented at:
            https://kusto.azurewebsites.net/docs/api/rest/streaming-ingest.html

def execute_streaming_ingest(
        self,
        database,
        table,
        stream,
        stream_format,
        mapping_name=None,
        accept=None,
        accept_encoding="gzip,deflate",
        connection="Keep-Alive",
        content_length=None,
        content_encoding=None,
        expect=None,
    ):
        """Executes streaming ingest against this client.
        :param str database: Target database.
        :param str table: Target table.
        :param io.BaseIO stream: stream object which contains the data to ingest.
        :param DataFormat stream_format: Format of the data in the stream.
        :param str mapping_name: Pre-defined mapping of the table. Required when stream_format is json/avro.
        Other optional params: optional request headers as documented at:
            https://kusto.azurewebsites.net/docs/api/rest/streaming-ingest.html
        """

        request_params = {"streamFormat": stream_format}

        if stream_format in self._mapping_required_formats and mapping_name is not None:
            request_params["mappingName"] = mapping_name

        request_headers = {
            "Accept-Encoding": accept_encoding,
            "Connection": connection,
            "x-ms-client-version": "Kusto.Python.StreamingClient:" + VERSION,
            "x-ms-client-request-id": "KPSC.execute;" + str(uuid.uuid4()),
            "Host": self._streaming_ingest_endpoint.split("/")[2],
        }

        if accept is not None:
            request_headers["Accept"] = accept
        if content_encoding is not None:
            request_headers["Content-Encoding"] = content_encoding
        if expect is not None:
            request_headers["Expect"] = expect
        if content_length is not None:
            request_headers["Content-Length"] = str(content_length)
        if self._auth_provider:
            request_headers["Authorization"] = self._auth_provider.acquire_authorization_header()

        response = self._session.post(
            self._streaming_ingest_endpoint + database + "/" + table,
            params=request_params,
            headers=request_headers,
            data=stream,
            timeout=KustoClient._query_default_timeout,
        )

        if response.status_code == 200:
            return KustoResponseDataSetV1(response.json())

        raise KustoServiceError([response.content], response)