[0-9]+)"
]
}}}
```
Thank you in Advance.
---
### Author:  [@Badger](https://discuss.elastic.co/u/Badger)
#### Post date: [November 18, 2021, 3:13pm UTC](https://discuss.elastic.co/t/how-to-add-country-name-field-based-on-mobile-number-using-mobile-number-using-logstash/289588/2 "2021-11-18T15:13:22Z")
See [here](https://discuss.elastic.co/t/logstash-link-fileds-in-aggregate-filter/167272/2). You would need to rewrite libphonenumber in Ruby, and then use a translate filter to map the country code to a country name.
---
### Author:  [@Divyank\_Mahalle](https://discuss.elastic.co/u/Divyank_Mahalle)
#### Post date: [December 4, 2021, 3:08pm UTC](https://discuss.elastic.co/t/how-to-add-country-name-field-based-on-mobile-number-using-mobile-number-using-logstash/289588/3 "2021-12-04T15:08:51Z")
Hi @Badger,
Thanks for your suggestion.
I took a different approach, using python script ([phone number library](https://pypi.org/project/phonenumbers/)) and enriching country code and country name fields to the index, as I am not well versed in ruby.
py script
```auto
def makeConnection():
elastic = Elasticsearch([{'host': es_host, 'port': es_port}], http_auth=(
es_uname, es_pwd), scheme="https", verify_certs=False)
return elastic
elastic = makeConnection()
def enrich_data():
get_data = elastic.search(index="type1", scroll='30m',body={
"size":10000,
"sort":{"event_timestamp":"asc"},
"query": {
"bool": {
"must_not": [
{
"exists": {
"field": "Country_Name"
}
}
]
}
}
}
)
scroll = elastic.scroll(scroll_id=get_data['_scroll_id'])
get_data['hits']['hits'] += scroll['hits']['hits']
if get_data['hits']['total']['value'] != 0:
for data in get_data['hits']['hits']:
Mobile_Number = data['_source']['Mobile_Number']
print(Mobile_Number)
phone_number= "+"+ Mobile_Number
phone_number_query = phonenumbers.parse(phone_number, None)
Country_name= geocoder.description_for_number(phone_number_query, "en")
Country_code= phone_number_query.country_code
try:
data['_source']['Country_Name'] = Country_name
data['_source']['Country_Code'] = Country_code
except:
pass
body_json = data['_source']
elastic.index(index="telebu-logs-smscountry", id=data['_id'],doc_type=data['_type'], body=body_json)
elastic.indices.refresh(index=data['_index'])
return
if __name__ == ' __main__':
enrich_data()
```
**Pros-**
- Country code, country name field is getting added successfully in index with 98% accuracy.
**Cons-**
- enrichment process is slow as compared to docs in an index, ex- 400 docs/min is enrichment rate, total docs are around 1m docs are getting added in index every hr in the same quantity.
As a single doc is getting checked and updated at a time the speed is slow, I am checking with bulk API update of docs using es helpers and scroll API but didn't work out in the above script.
Any suggestion regarding the above will be highly helpful.
---
### Author:  [@system](https://discuss.elastic.co/u/system)
#### Post date: [January 1, 2022, 3:09pm UTC](https://discuss.elastic.co/t/how-to-add-country-name-field-based-on-mobile-number-using-mobile-number-using-logstash/289588/4 "2022-01-01T15:09:27Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.