如何在elasticsearch中索引twitter数据？

PUT /twitter
{
  "settings": {
    "number_of_shards": 1,
    "number_of_replicas": 1
  },
  "mappings": {
    "properties": {
      "id": { "type": "keyword" },
      "text": { "type": "text" },
      "user": {
        "properties": {
          "id": { "type": "keyword" },
          "name": { "type": "text" },
          "screen_name": { "type": "keyword" }
        }
      },
      "created_at": { "type": "date" },
      "retweet_count": { "type": "integer" },
      "favorite_count": { "type": "integer" }
    }
  }
}

import tweepy
import json

# 填入你的Twitter API凭证
consumer_key = 'YOUR_CONSUMER_KEY'
consumer_secret = 'YOUR_CONSUMER_SECRET'
access_token = 'YOUR_ACCESS_TOKEN'
access_token_secret = 'YOUR_ACCESS_TOKEN_SECRET'

# 认证
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
api = tweepy.API(auth)

# 获取推文
tweets = api.search_tweets(q="your_query", count=100)

# 将推文转换为JSON格式
tweets_json = [tweet._json for tweet in tweets]

from elasticsearch import Elasticsearch

# 连接到Elasticsearch
es = Elasticsearch([{'host': 'localhost', 'port': 9200}])

# 索引推文
for tweet in tweets_json:
    es.index(index='twitter', body=tweet)