spinframework
diff --git a/‎crates/key-value-spin/src/store.rs‎
Lines changed: 9 additions & 1 deletion b/‎crates/key-value-spin/src/store.rs‎
Lines changed: 9 additions & 1 deletion
diff --git a/‎crates/telemetry/src/env.rs‎
Lines changed: 10 additions & 5 deletions b/‎crates/telemetry/src/env.rs‎
Lines changed: 10 additions & 5 deletions
diff --git a/‎crates/trigger-http/src/server.rs‎
Lines changed: 10 additions & 7 deletions b/‎crates/trigger-http/src/server.rs‎
Lines changed: 10 additions & 7 deletions
@@ -159,7 +159,15 @@ impl Store for SqliteStore {
     }
 
     async fn exists(&self, key: &str) -> Result<bool, Error> {
-        Ok(self.get(key, usize::MAX).await?.is_some())
+        task::block_in_place(|| {
+            self.connection
+                .lock()
+                .unwrap()
+                .prepare_cached("SELECT 1 FROM spin_key_value WHERE store=$1 AND key=$2 LIMIT 1")
+                .map_err(log_error)?
+                .exists([&self.name, key])
+                .map_err(log_error)
+        })
     }
 
     async fn get_keys(&self, max_result_bytes: usize) -> Result<Vec<String>, Error> {
 
@@ -1,4 +1,4 @@
-use std::env::VarError;
+use std::{env::VarError, sync::OnceLock};
 
 use opentelemetry_otlp::{
     OTEL_EXPORTER_OTLP_ENDPOINT, OTEL_EXPORTER_OTLP_LOGS_ENDPOINT,
@@ -47,11 +47,16 @@ pub fn otel_metrics_enabled() -> bool {
 /// - `OTEL_EXPORTER_OTLP_LOGS_ENDPOINT`
 ///
 /// Note that this is overridden if OTEL_SDK_DISABLED is set and not empty.
+///
+/// The result is cached after the first call because this is checked on every guest log write.
 pub fn otel_logs_enabled() -> bool {
-    any_vars_set(&[
-        OTEL_EXPORTER_OTLP_ENDPOINT,
-        OTEL_EXPORTER_OTLP_LOGS_ENDPOINT,
-    ]) && !otel_sdk_disabled()
+    static ENABLED: OnceLock<bool> = OnceLock::new();
+    *ENABLED.get_or_init(|| {
+        any_vars_set(&[
+            OTEL_EXPORTER_OTLP_ENDPOINT,
+            OTEL_EXPORTER_OTLP_LOGS_ENDPOINT,
+        ]) && !otel_sdk_disabled()
+    })
 }
 
 /// Returns a boolean indicating if the compatibility layer that emits tracing events from
 
@@ -98,6 +98,8 @@ pub struct HttpServer<F: RuntimeFactors> {
     router: Router,
     /// The app being triggered.
     trigger_app: Arc<TriggerApp<F>>,
+    /// The application name, resolved once for use as the `app_id` telemetry attribute.
+    app_id: Arc<str>,
     // Component ID -> component trigger config
     component_trigger_configs: HashMap<spin_http::routes::TriggerLookupKey, HttpTriggerConfig>,
     // Component ID -> handler type
@@ -158,6 +160,12 @@ impl<F: RuntimeFactors> HttpServer<F> {
 
         let trigger_app = Arc::new(trigger_app);
 
+        let app_id: Arc<str> = trigger_app
+            .app()
+            .get_metadata(APP_NAME_KEY)?
+            .unwrap_or_else(|| "<unnamed>".into())
+            .into();
+
         let component_handler_types = component_trigger_configs
             .iter()
             .filter_map(|(key, trigger_config)| match key {
@@ -180,6 +188,7 @@ impl<F: RuntimeFactors> HttpServer<F> {
             find_free_port,
             router,
             trigger_app,
+            app_id,
             http1_max_buf_size,
             component_trigger_configs,
             component_handler_types,
@@ -350,18 +359,12 @@ impl<F: RuntimeFactors> HttpServer<F> {
         client_addr: SocketAddr,
     ) -> anyhow::Result<Response<Body>> {
         set_req_uri(&mut req, server_scheme)?;
-        let app_id = self
-            .trigger_app
-            .app()
-            .get_metadata(APP_NAME_KEY)?
-            .unwrap_or_else(|| "<unnamed>".into());
-
         let lookup_key = route_match.lookup_key();
 
         spin_telemetry::metrics::counter!(
             spin.request_count = 1,
             trigger_type = "http",
-            app_id = app_id,
+            app_id = self.app_id.clone(),
             component_id = lookup_key.to_string()
         );