I want to use Python in Elasticsearch. So I wrote an Authentication code in Python for Elasticsearch. But I'm getting the error "TypeError: 'Session' object is not callable". Here's the code:
import requests
from requests import Session
from requests.auth import HTTPBasicAuth
uname = 'elastic'
pswd = 'elastic'
session = requests.Session()
session.auth = HTTPBasicAuth(uname, pswd)
res = requests.get('http://localhost:9200',auth=session)
print(res.content)
Where am I going wrong?
Instead of sessions you can directly use following method to connect to elasticsearch server:
import requests
from requests.auth import HTTPBasicAuth
from pprint import pprint
username = 'elastic'
password = 'elastic'
response = requests.get('http://localhost:9200', auth = HTTPBasicAuth(username, password))
pprint(response.content)
Is there any reason why you wouldn't use the elasticsearch python client library.
from elasticsearch import Elasticsearch
# you can use RFC-1738 to specify the url
es = Elasticsearch(['https://user:secret@localhost:443'])
# ... or specify common parameters as kwargs
es = Elasticsearch(
['localhost', 'otherhost'],
http_auth=('user', 'secret'),
scheme="https",
port=443,
)
# SSL client authentication using client_cert and client_key
from ssl import create_default_context
context = create_default_context(cafile="path/to/cert.pem")
es = Elasticsearch(
['localhost', 'otherhost'],
http_auth=('user', 'secret'),
scheme="https",
port=443,
ssl_context=context,
)
https://elasticsearch-py.readthedocs.io/en/master/index.html
Once you have the elasticsearch object it is easy to query your index
res = es.get(index="test-index", doc_type='tweet')
print(res['_source'])
I would recommend using the elasticsearch library to connect.
Here is an example:
from elasticsearch import Elasticsearch
es = Elasticsearch(['hostname:port'],http_auth=('username','password'))
#check if it exists...
if es.exists(index="test",doc_type="test",id="1234"):
es.update(index="test",doc_type="test",id="1234",body{"doc": {"hi":"data"}})
else:
es.create(index="test",doc_type="test",id="1234",body={"hi":"data"})
As per documentation http://docs.python-requests.org/en/master/user/authentication/
remove the session object and try this out
requests.get('url', auth=HTTPBasicAuth('user', 'pass'))
If you want to use Session object, first let's clarify what is it for:
The Session object allows you to persist certain parameters across requests.
This is how you could change your code:
session = requests.Session()
session.auth = HTTPBasicAuth(uname, pswd)
res = session.get('http://localhost:9200')
And the get will use auth defined above it implicitly.
Check the page linked above, there are plenty examples.
And if you don't intend to reuse the connection, you can drop Session and go with auth in the get, like Narenda suggests in the other answer.
Try this simple way to do this.
import requests
from requests.auth import HTTPBasicAuth
res = requests.get(url="url", auth=HTTPBasicAuth("username", "password"))
print(res.json())
I hope this helps.
First create a Basic header auth token based from your username and pass using base64 module, if you dont know how to use it just create Basic Authentication Header Here:
After doing so, create a dictionary which would be passed as the authentication header. See sample code below:
import requests
#username = elastic password = elastic
auth_token = 'ZWxhc3RpYzplbGFzdGlj'
head = head = {
'Content-Type' : 'application/json; charset=utf8',
'Authorization' : 'Basic %s' % auth_token,
'User-Agent': 'Mozilla/5.0 (Windows NT 6.0; WOW64; rv:24.0) Gecko/20100101
Firefox/24.0'
}
res = requests.get('http://localhost:9200', header=head)
print(res.json())
requestsas tag to your question?