Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo un requisito en el que necesito enviar información de metadatos del archivo (como nombre de archivo, ruta de archivo, etc.) a Azure Event Hub / Azure Event Grid cada vez que se crea un nuevo archivo en el contenedor de Azure Datalake. ¿Cuál sería la forma ideal de hacerlo? . . . Read more
Estoy intentando utilizar el ‘camel-azure-storage-datalake-kafka-connector’ para conectarme desde Kafka a Azure ADLS Gen2. Tengo un equipo Linux ejecutando Docker con las imágenes debezium/zookeeper, debezium/kafka y debezium/connect. Recoger cambios de las tablas cdc con el conector debezium funciona perfectamente, por lo que tengo temas con mensajes. Desde aquí estoy intentando utilizar . . . Read more
Acabo de encontrar las propiedades “lastModifiedTime” y “ExpiryTime” en la clase DirectoryEntry.
Tengo el siguiente modelo: Parámetro Valor Lo estoy enviando a Stream Analytics, que me produce un cambio en el Valor basado en el valor del Parámetro. Estoy almacenando esta salida en Data Lake gen2 en el siguiente formato: Parámetro deltaValor = Valor – LAG(Valor) ¿Cómo puedo encontrar el valor para . . . Read more
Así que necesito usar Presto para conectarme a ADLS. Ahora, he leído que Hive puede conectarse a ADLS, y que Presto se puede utilizar para conectarse a Hive. Sin embargo, no pude encontrar ningún artículo sobre cómo conectarse a ADLS usando Hive con Python. Gracias de antemano.