We have a DLT pipeline we've created that is using autoloader file notification mode. The pipeline ran fine before moving it to UC. Now that we're using UC, we are getting an AWS permissions issue when the autoloader file notification mode is set to true. We've checked all of our AWS permissions and everything is configured correctly. We do not want to parameterize our accesskey or secret keys. Have there been any updates about this?
@dlt.table(
table_properties={
"quality": "bronze",
"pipelines.autoOptimize.managed":"true",
}
)
def bronze():
return (
spark.readStream.format("cloudFiles")
.option("cloudFiles.format", "avro")
.option("cloudFiles.useNotifications", "true")
.option("cloudFiles.backfillInterval", "1 day")
.option("pathGlobFilter", "*.avro")
.option("avroSchema", avro_schema)
.load(data_source)