プログラム概要
python3.7においてElasticsearchにアクセスできているか確認するプログラムで、テキストをカウントします。Elasticsearchの中にテキストデータを入れるためのプログラムとテキストデータで構成しています。エラーメッセージが大量に表示されて何をどうすればいいのか分からない状態です。何を訂正すればエラーは解消されるでしょうか。
開発環境
PyCharm2019.2
モジュール:elasticsearch
elasticsearch-7.8.0とanalysis-kuromoji-7.8.0をダウンロードしてあります。
理想の実行結果
(10, [])
コード
python
1from elasticsearch import Elasticsearch, helpers 2es = Elasticsearch() 3 4def load(): 5 with open('./dialogue_pairs.txt', encoding='utf-8') as f: 6 for i, __ in enumerate(f): 7 print(i, '...', end='\r') 8 __ = __.split('\t') 9 tweet = __[0].strip() 10 reply = __[1].strip() 11 item = {'_index':'dialogue_pair', '_type':'docs', '_source':{ 'query':tweet, 'response':reply }} 12 yield item 13 14if __name__ == '__main__': 15 print(helpers.bulk(es, load()))
dialogue_pairs.txt
txt
1 2最近はまっていることなどはありますか? 朝ドラでしょうか。 3朝ドラでしょうか。 どんなタイトルなんですか? 4どんなタイトルなんですか? スカーレット、です。 5スカーレット、です。 みどころはどのあたりですか? 6みどころはどのあたりですか? 笑えるところです。劇中の会話が漫才みたいな時があります。大阪制作らしいドラマです。 7笑えるところです。劇中の会話が漫才みたいな時があります。大阪制作らしいドラマです。 笑えるのは良いですね、感動や悲劇などもあるのでしょうか? 8笑えるのは良いですね、感動や悲劇などもあるのでしょうか? 時々あります。 9時々あります。 70年くらい前の時代設定なんでしたっけ 1070年くらい前の時代設定なんでしたっけ 現時点の放送では、昭和34年という設定です。 11現時点の放送では、昭和34年という設定です。 激動の時代ですね。タイトルの由来が気になります
エラーメッセージ
Traceback (most recent call last): File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connection.py", line 157, in _new_conn (self._dns_host, self.port), self.timeout, **extra_kw File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\util\connection.py", line 84, in create_connection raise err File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\util\connection.py", line 74, in create_connection sock.connect(sa) ConnectionRefusedError: [WinError 10061] 対象のコンピューターによって拒否されたため、接続できませんでした。 During handling of the above exception, another exception occurred: Traceback (most recent call last): File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\connection\http_urllib3.py", line 233, in perform_request method, url, body, retries=Retry(False), headers=request_headers, **kw File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 720, in urlopen method, url, error=e, _pool=self, _stacktrace=sys.exc_info()[2] File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\util\retry.py", line 376, in increment raise six.reraise(type(error), error, _stacktrace) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\packages\six.py", line 735, in reraise raise value File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 672, in urlopen chunked=chunked, File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 387, in _make_request conn.request(method, url, **httplib_request_kw) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1244, in request self._send_request(method, url, body, headers, encode_chunked) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1290, in _send_request self.endheaders(body, encode_chunked=encode_chunked) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1239, in endheaders self._send_output(message_body, encode_chunked=encode_chunked) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1026, in _send_output self.send(msg) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 966, in send self.connect() File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connection.py", line 184, in connect conn = self._new_conn() File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connection.py", line 169, in _new_conn self, "Failed to establish a new connection: %s" % e urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x07DF7B70>: Failed to establish a new connection: [WinError 10061] 対象のコンピューターによって拒否されたため、接続できませんでした。 During handling of the above exception, another exception occurred: Traceback (most recent call last): File "C:/Users/beret/otintin/insert.py", line 16, in <module> print(helpers.bulk(es, load())) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\helpers\actions.py", line 360, in bulk for ok, item in streaming_bulk(client, actions, *args, **kwargs): File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\helpers\actions.py", line 290, in streaming_bulk **kwargs File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\helpers\actions.py", line 217, in _process_bulk_chunk for item in gen: File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\helpers\actions.py", line 166, in _process_bulk_chunk_error raise error File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\helpers\actions.py", line 205, in _process_bulk_chunk resp = client.bulk("\n".join(bulk_actions) + "\n", *args, **kwargs) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\client\utils.py", line 139, in _wrapped return func(*args, params=params, headers=headers, **kwargs) File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\client\__init__.py", line 433, in bulk body=body, File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\transport.py", line 352, in perform_request timeout=timeout, File "C:\Users\beret\AppData\Local\Programs\Python\Python37-32\lib\site-packages\elasticsearch\connection\http_urllib3.py", line 245, in perform_request raise ConnectionError("N/A", str(e), e) elasticsearch.exceptions.ConnectionError: ConnectionError(<urllib3.connection.HTTPConnection object at 0x07DF7B70>: Failed to establish a new connection: [WinError 10061] 対象のコンピューターによって拒否されたため、接続できませんでした。) caused by: NewConnectionError(<urllib3.connection.HTTPConnection object at 0x07DF7B70>: Failed to establish a new connection: [WinError 10061] 対象のコンピューターによって拒否されたため、接続できませんでした。)
あなたの回答
tips
プレビュー