Update astream_es_data_process.rb