Moibe commited on
Commit
e9bc1c2
·
1 Parent(s): e602d6a

Remove Inference Backup Provider

Browse files
Files changed (5) hide show
  1. cloudfunction.py +0 -62
  2. conexion_firebase.py +0 -1
  3. creaLog.py +0 -5
  4. espacios.py +0 -41
  5. funciones.py +8 -5
cloudfunction.py DELETED
@@ -1,62 +0,0 @@
1
- # main.py o donde definas tus funciones
2
-
3
- import firebase_admin
4
- from firebase_functions import pubsub_fn, options
5
- from firebase_admin import firestore, exceptions # Import exceptions for better error handling
6
-
7
- # Inicializa Firebase Admin si no lo has hecho ya en tu proyecto
8
- # Esto generalmente se hace una vez en el punto de entrada de tus funciones (ej. en __init__.py o al inicio de tu main.py)
9
- # Puedes usar un bloque try/except para evitar reinicializar si ya está inicializado.
10
- # try:
11
- # firebase_admin.get_app()
12
- # except ValueError:
13
- # firebase_admin.initialize_app()
14
-
15
- # Obtén una referencia a la base de datos de Firestore con el nombre 'nowme'
16
- # Asegúrate de que firebase_admin.initializeApp() se haya ejecutado antes de obtener esta referencia.
17
- # firestore.client() obtiene el cliente para la app por defecto,
18
- # y luego .instance('nowme') especifica la base de datos con nombre.
19
- db = firestore.client().instance('nowme')
20
-
21
- @pubsub_fn.on_message_published(
22
- # Puedes dar un nombre lógico al trabajo programado (Cloud Scheduler job) si quieres
23
- # topic="increment-segundos-job", # Este parámetro no es necesario para schedule, Firebase lo gestiona
24
- schedule="every 24 hours at 16:00",
25
- timezone="America/Mexico_City", # Establece la zona horaria a Ciudad de México
26
- # Opcional: puedes añadir opciones de runtime aquí si lo necesitas
27
- # memory=options.MemoryOption.GB_1, # Ejemplo: 1 GB de memoria
28
- # timeout_sec=300, # Ejemplo: 5 minutos de timeout
29
- )
30
- def incrementar_segundos_python(event: pubsub_fn.CloudEvent) -> None:
31
- """
32
- Cloud Function en Python activada por un programador
33
- para incrementar el campo 'segundos' en un documento de Firestore.
34
- """
35
- print(f"Function incrementar_segundos_python activada a las {event.time} por mensaje ID: {event.id}")
36
- # Para este caso, no necesitamos los datos específicos del evento Pub/Sub
37
-
38
- # Referencia al documento específico: colección 'nowme', documento 'sosa'
39
- doc_ref = db.collection('nowme').document('sosa')
40
-
41
- try:
42
- # Usa update con FieldValue.increment para una actualización atómica segura
43
- # Esto es especialmente bueno para valores numéricos que pueden ser
44
- # modificados por múltiples fuentes al mismo tiempo.
45
- doc_ref.update({
46
- "segundos": firestore.FieldValue.increment(1500)
47
- })
48
- # print("Campo 'segundos' actualizado con éxito (+1500) en el documento 'nowme/sosa'.")
49
-
50
- except exceptions.NotFound:
51
- print("Error: Documento nowme/sosa no encontrado. No se pudo actualizar.")
52
- # Puedes decidir si quieres crear el documento si no existe,
53
- # pero update() solo funciona si el documento ya existe.
54
- # Si quieres crearlo si no existe, usarías set(..., merge=True).
55
- # doc_ref.set({"segundos": 1500}, merge=True) # Ejemplo de cómo crear/actualizar
56
-
57
- except Exception as e:
58
- #print(f"Error al actualizar el documento nowme/sosa: {e}")
59
- # Puedes lanzar la excepción si quieres que Cloud Functions lo reporte como un fallo.
60
- # raise e
61
- pass # O simplemente pasar para que la Function no se marque como fallo en este caso
62
-
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
conexion_firebase.py CHANGED
@@ -1,6 +1,5 @@
1
  import firebase_admin
2
  from datetime import datetime
3
- from firebase_admin import auth
4
  from firebase_admin import firestore
5
  from firebase_admin import credentials
6
 
 
1
  import firebase_admin
2
  from datetime import datetime
 
3
  from firebase_admin import firestore
4
  from firebase_admin import credentials
5
 
creaLog.py DELETED
@@ -1,5 +0,0 @@
1
- import conexion_firebase
2
-
3
-
4
- conexion_firebase.registraLog("sosa", "Ensalada de pollo", "Flux-Dev", 42)
5
-
 
 
 
 
 
 
espacios.py DELETED
@@ -1,41 +0,0 @@
1
- import herramientas
2
-
3
- # server = herramientas.getFluxServer()
4
- # print("Server elegido: ", server)
5
- # print("El type es: ", type(server))
6
-
7
- espacio = [
8
- {
9
- "id": "black-forest-labs/FLUX.1-dev",
10
- "static_kwargs": {
11
- "api_name": "/infer",
12
- }
13
- },
14
- # {
15
- # "id": "black-forest-labs/FLUX.1-schnell",
16
- # "static_kwargs": {
17
- # "api_name": "/infer",
18
- # }
19
- # },
20
- # {
21
- # "id": "NihalGazi/FLUX-Pro-Unlimited",
22
- # "static_kwargs": {
23
- # "api_name": "/generate_image",
24
- # "server_choice": server,
25
- # }
26
- # },
27
- # {
28
- # "id": "HiDream-ai/HiDream-I1-Dev",
29
- # "static_kwargs": {
30
- # "api_name": "/infer",
31
- #
32
- # }
33
- # },
34
- # {
35
- # "id": "stabilityai/stable-diffusion",
36
- # "static_kwargs": {
37
- # "api_name": "/generate",
38
- #
39
- # }
40
- # }
41
- ]
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
funciones.py CHANGED
@@ -76,12 +76,15 @@ def genera_platillo_inference(platillo):
76
 
77
  client = gradio_client.Client(datos_modelo['ruta'], hf_token=globales.llave)
78
 
79
- creditos_restantes_inference = conexion_firebase.obtenDato('nowme', servidor, 'inferencias')
 
 
80
 
81
- if creditos_restantes_inference > 0:
82
- provedor_seleccionado = globales.proveedor
83
- else:
84
- provedor_seleccionado = globales.proveedor_back
 
85
 
86
  prompt = globales.previo + platillo
87
  print("Platillo enviado:", platillo)
 
76
 
77
  client = gradio_client.Client(datos_modelo['ruta'], hf_token=globales.llave)
78
 
79
+ #creditos_restantes_inference = conexion_firebase.obtenDato('nowme', servidor, 'inferencias')
80
+
81
+ provedor_seleccionado = globales.proveedor
82
 
83
+ #Ahora se usará un proveedor único para inferencias.
84
+ # if creditos_restantes_inference > 0:
85
+ # provedor_seleccionado = globales.proveedor
86
+ # else:
87
+ # provedor_seleccionado = globales.proveedor_back
88
 
89
  prompt = globales.previo + platillo
90
  print("Platillo enviado:", platillo)