質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.50%
Elasticsearch

Elasticsearchは、クラウド向けに構築された、RESTful な API を提供する分散型のサーチエンジンアプリケーションです。

Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

PyCharm

エディター・開発ツール

Q&A

0回答

1385閲覧

pythonからElasticsearchにアクセスできない!

Ponde_ling

総合スコア8

Elasticsearch

Elasticsearchは、クラウド向けに構築された、RESTful な API を提供する分散型のサーチエンジンアプリケーションです。

Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

PyCharm

エディター・開発ツール

0グッド

0クリップ

投稿2020/07/17 17:30

プログラム概要

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] 対象のコンピューターによって拒否されたため、接続できませんでした。)

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

まだ回答がついていません

会員登録して回答してみよう

アカウントをお持ちの方は

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.50%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問