使用python Elasticsearch映射地理点后如何获取一些原始json字段？

Question

我想通过地理点映射获取一些原始数据。我需要单独使用“geo”获取卫星名称和时间戳

我使用 python Elasticsearch 从 Restful API 获取数据。

settings = { "settings": {
                 "number_of_shards":1,
                  'number_of_replicas':0
                 },
      "mappings" : { 
           "document" : {
                "properties":{
                    "geo": {
                       "type": "geo_point"
                            }
                          }
                        } 
                     } 
                  }

es.indices.create(index = "new", body=settings)

def collect_data():
  data = requests.get(url = URL).json() 
  del data['positions'][1]

  new_data = {'geo':{'lat':data['positions'][0]['satlatitude'],
               'lon':data['positions'][0]['satlongitude']}}, {data['info'][0]['satname']} ,   
                {data['positions'][0]['timestamp']} 



 es.index(index='new', doc_type='document', body=new_data)
schedule.every(10).seconds.do(collect_data)


while True:
 schedule.run_pending()
 time.sleep(1) 

Error received:
SerializationError: (({'geo': {'lat': 37.43662067, 'lon': -26.09384821}}, {1591391688}), 
TypeError("Unable to serialize {1591391688} (type: <class 'set'>)"))

RESTful json 数据样本--- {'info': {'satname': 'SPACE STATION', 'satid': 25544, 'transactionscount': 0}, '仓位': [{'satlatitude': 28.89539607, 'satlongitude'：90.44547739，'sataltitude'：420.36，'azimuth'：12.46， “海拔”：-52.81，“ra”：215.55022984，“dec”：-5.00234017，“时间戳”：1591196844，“黯淡”：
真的}]}

我需要有“geo”、“satnam”和“timestamp”。我想知道如何才能获得正确的结果。

Answer 1

看起来您在没有密钥的情况下设置了时间戳和卫星名称，试试这个来处理数据：

import json
from datetime import datetime

response_json = '''
{
    "info": {
        "satname": "SPACE STATION",
        "satid": 25544,
        "transactionscount": 0
    },
    "positions": [
        {
            "satlatitude": 28.89539607,
            "satlongitude": 90.44547739,
            "sataltitude": 420.36,
            "azimuth": 12.46,
            "elevation": -52.81,
            "ra": 215.55022984,
            "dec": -5.00234017,
            "timestamp": 1591196844,
            "eclipsed": true
        }
    ]
}
'''

response_data = json.loads(response_json)



def process_data(data):
    return {
        'satname': response_data['info']['satname'],
        # comvert unix timestamp to iso time
        'timestamp': datetime.fromtimestamp(response_data['positions'][0]['timestamp']).isoformat(),
        'geo': {
            'lat': response_data['positions'][0]['satlatitude'],
            'lon': response_data['positions'][0]['satlongitude']
        }
    }

print(process_data(response_data))

输出：

{'satname': 'SPACE STATION', 'timestamp': '2020-06-03T15:07:24', 'geo': {'lat': 28.89539607, 'lon': 90.44547739}}