print('entered') import os import time import fiona import requests import utm from geopy.geocoders import Nominatim import time import json import pandas as pd from fastkml import kml from socket import * from oct2py import octave from io import BytesIO import base64 import xlrd import csv from statistics import median import math import firebase_admin from firebase_admin import credentials from firebase_admin import db from firebase_admin import messaging import threading import xlsxwriter import numpy as np import datetime import os from numba import jit, cuda from firebase_admin import firestore from make_on_the_go_farm_image import make_on_the_go_farm_image from sentinelhub import ( WebFeatureService, BBox, CRS, MimeType, CRS, BBox, WmsRequest, DataCollection, ) from get_polygon_mask import get_polygon_mask import traceback from google.cloud import storage import os from google.oauth2 import service_account import datetime from datetime import date import traceback from gen_report_new2 import gen_report_new from google.cloud import storage from oauth2client.service_account import ServiceAccountCredentials import os import firebase_admin from firebase_admin import credentials from firebase_admin import db import datetime storage_client = storage.Client.from_service_account_json("servicekey.json") bucket_name = "farmbase-b2f7e.appspot.com" cred = service_account.Credentials.from_service_account_file("servicekey.json") # cred = credentials.Certificate('servicekey.json') bucket = storage_client.bucket(bucket_name) try: firebase_admin.initialize_app( credentials.Certificate("servicekey.json"), {"databaseURL": "https://farmbase-b2f7e-31c0c.firebaseio.com/"}, ) except: print("fire running") print('step 1') db_firestore = firestore.client() sentinelSettings = db.reference("SentinelSettings").get() clientID = sentinelSettings["ClientID"] clientSecret = sentinelSettings["ClientSecret"] wmsID = sentinelSettings["WMSID"] rviID = sentinelSettings["RVIID"] demID = sentinelSettings["DEMID"] images_arr = ["TCI", "NDVI", "NDWI", "NDRE", "RECL", "RVI", "RSM"] day_gap = 5 today = date.today() ndvi_val, ndwi_val = 0, 0 imageDate = today.strftime("%Y%m%d") print('step 2') kkk = 0 uid = 'TCXcp5VIsfhHZrh0nm2VsgBtcGy2' if not os.path.exists(uid): os.makedirs(uid) all_polygons_arr = [] n_tmux = 28 print('step 4') all_polygons_arr = [] temp_list = db.reference("PaidMonitoredFields").child("PMF").child(uid).get(False, True) for fieldid, tmp in temp_list.items(): polygons_obj = db.reference("PaidMonitoredFields").child("PMF").child(uid).child(fieldid).child('Polygons').get(False, True) try: for polygonid, temp_p in polygons_obj.items(): polygon_obj = db.reference("PaidMonitoredFields").child("PMF").child(uid).child(fieldid).child('Polygons').child(polygonid).get() try: sensed_days_obj = polygon-obj["SensedDays"] health_obj = polygon_obj["Health"] sensed_days_arr = [] for sensed_day, tmp in sensed_days_obj.items(): sensed_day = sensed_day.replace("-","") sensed_days_arr.append(sensed_day) latest_day = max(sensed_days_arr) latest_health_obj = health_obj[latest_day] ndvi = latest_health_obj.get("NDVI", None) ndwi = latest_health_obj.get("NDWI", None) ndre = latest_health_obj.get("NDRE", None) recl = latest_health_obj.get("RECL", None) rvi = latest_health_obj.get("RVI", None) rsm = latest_health_obj.get("RSM", None) farmer_code = polygon_obj["Name"] land_id = polyon_obj["PhoneNumber"] all_polygons_arr.append([farmer_code, land_id, latest_day, ndvi, ndwi, ndre, recl, rvi, rsm, fieldid, polygonid]) except: print(traceback.format_exc()) except: print(traceback.format_exc()) with open('gavl_new', 'w') as f: # using csv.writer method from CSV package write = csv.writer(f) write.writerow(['Farmer Code', 'Land ID', 'Satellite Visit Date', 'NDVI', 'NDWI', 'NDRE', 'RECL' 'RVI','RSM', 'Field ID', 'Polygon ID']) write.writerows(all_polygons_arr)