Skip to content

Commit 3b507fd

Browse files
Copilotphilnach
andcommitted
Add documentation and logging improvements for MongoDB query filtering
Co-authored-by: philnach <19275540+philnach@users.noreply.github.com>
1 parent 8fae670 commit 3b507fd

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

Extensions/Mongo/Cosmos.DataTransfer.MongoExtension/MongoDataSourceExtension.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ public async IAsyncEnumerable<IDataItem> EnumerateCollectionAsync(Context contex
5151
}
5252
else
5353
{
54+
logger.LogInformation("No query filter specified for collection '{Collection}', reading all documents", collectionName);
5455
// Use existing queryable approach when no filter is specified
5556
documents = GetAllDocumentsAsync(collection);
5657
}
@@ -88,6 +89,7 @@ private async IAsyncEnumerable<BsonDocument> GetQueryDocumentsAsync(IRepository<
8889
}
8990
else
9091
{
92+
logger.LogInformation("Treating query input as direct JSON string (file does not exist): {Query}", query);
9193
queryJson = query;
9294
}
9395
}

Extensions/Mongo/Cosmos.DataTransfer.MongoExtension/Settings/MongoSourceSettings.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ public class MongoSourceSettings : MongoBaseSettings
55
{
66
public string? Collection { get; set; }
77

8+
/// <summary>
9+
/// MongoDB query filter to apply during data migration. Can be specified as:
10+
/// - Direct JSON query string (e.g., "{\"field\":{\"$gte\":\"value\"}}")
11+
/// - Path to a JSON file containing the query
12+
/// </summary>
813
public string? Query { get; set; }
914

1015
[SensitiveValue]

0 commit comments

Comments
 (0)