influxdb3 fails to query column with uppercase in the name

[jnativio2]

I created a downsampler plugin for a table with column named in camel-back style. The query passed to influxdb3 client is correct, but it fails with this message:

2025-08-27 16-30-00 [ERROR] error: error while planning query: Schema error: No field named accountid. Valid fields are _time, record_count, time_from, time_to, "internalSuccessfulValue_avg", "remoteSuccessfulValue_avg", "totalTimeInMs_avg", "appMetrics_ErxRouting_transaction"."accountId", "appMetrics_ErxRouting_transaction"."accountName", "appMetrics_ErxRouting_transaction".application, "appMetrics_ErxRouting_transaction"."applicationVersion", "appMetrics_ErxRouting_transaction"."asyncStatusMessageFlag", "appMetrics_ErxRouting_transaction".datacenter, "appMetrics_ErxRouting_transaction".direction, "appMetrics_ErxRouting_transaction".env, "appMetrics_ErxRouting_transaction".host, "appMetrics_ErxRouting_transaction"."httpErrorType", "appMetrics_ErxRouting_transaction"."httpStatus", "appMetrics_ErxRouting_transaction"."internalSuccessful", "appMetrics_ErxRouting_transaction"."messageCategory", "appMetrics_ErxRouting_transaction"."messageType", "appMetrics_ErxRouting_transaction"."messageVersion", "appMetrics_ErxRouting_transaction".os, "appMetrics_ErxRouting_transaction".pool, "appMetrics_ErxRouting_transaction"."portalId", "appMetrics_ErxRouting_transaction"."portalName", "appMetrics_ErxRouting_transaction"."receiverResponse", "appMetrics_ErxRouting_transaction"."remoteSuccessful", "appMetrics_ErxRouting_transaction"."routableEntityIdQualifier", "appMetrics_ErxRouting_transaction".server_role, "appMetrics_ErxRouting_transaction"."accountId", "appMetrics_ErxRouting_transaction"."accountName", "appMetrics_ErxRouting_transaction".application, "appMetrics_ErxRouting_transaction"."applicationVersion", "appMetrics_ErxRouting_transaction"."asyncStatusMessageFlag", "appMetrics_ErxRouting_transaction"."asyncStatusMessageFlagValue", "appMetrics_ErxRouting_transaction".datacenter, "appMetrics_ErxRouting_transaction".direction, "appMetrics_ErxRouting_transaction".env, "appMetrics_ErxRouting_transaction".host, "appMetrics_ErxRouting_transaction"."httpErrorType", "appMetrics_ErxRouting_transaction"."httpStatus", "appMetrics_ErxRouting_transaction"."internalProcessingTimeInMs", "appMetrics_ErxRouting_transaction"."internalSuccessful", "appMetrics_ErxRouting_transaction"."internalSuccessfulValue", "appMetrics_ErxRouting_transaction"."messageCategory", "appMetrics_ErxRouting_transaction"."messageType", "appMetrics_ErxRouting_transaction"."messageVersion", "appMetrics_ErxRouting_transaction".os, "appMetrics_ErxRouting_transaction"."outgoingUrl", "appMetrics_ErxRouting_transaction".pool, "appMetrics_ErxRouting_transaction"."portalId", "appMetrics_ErxRouting_transaction"."portalName", "appMetrics_ErxRouting_transaction"."receiverResponse", "appMetrics_ErxRouting_transaction"."remoteSuccessful", "appMetrics_ErxRouting_transaction"."remoteSuccessfulValue", "appMetrics_ErxRouting_transaction"."routableEntityId", "appMetrics_ErxRouting_transaction"."routableEntityIdQualifier", "appMetrics_ErxRouting_transaction"."senderMessageId", "appMetrics_ErxRouting_transaction".server_role, "appMetrics_ErxRouting_transaction".time, "appMetrics_ErxRouting_transaction"."totalTimeInMs". executing query: SELECT DATE_BIN(INTERVAL '5 minutes', time, '1970-01-01T00:00:00Z') AS _time, count(*) AS record_count, MIN(time) AS time_from, MAX(time) AS time_to, avg("internalSuccessfulValue") as "internalSuccessfulValue_avg", avg("remoteSuccessfulValue") as "remoteSuccessfulValue_avg", avg("totalTimeInMs") as "totalTimeInMs_avg", "accountId", "accountName", "application", "applicationVersion", "asyncStatusMessageFlag", "datacenter", "direction", "env", "host", "httpErrorType", "httpStatus", "internalSuccessful", "messageCategory", "messageType", "messageVersion", "os", "pool", "portalId", "portalName", "receiverResponse", "remoteSuccessful", "routableEntityIdQualifier", "server_role" FROM 'appMetrics_ErxRouting_transaction' WHERE time >= '2025-08-27T20:24:00Z' AND time < '2025-08-27T20:29:00Z' GROUP BY _time, accountId, accountName, application, applicationVersion, asyncStatusMessageFlag, datacenter, direction, env, host, httpErrorType, httpStatus, internalSuccessful, messageCategory, messageType, messageVersion, os, pool, portalId, portalName, receiverResponse, remoteSuccessful, routableEntityIdQualifier, server_role

The same happens running the same query in CLI.

[hiltontj]

@jnativio2 in your GROUP BY clause you need to quote column names:

GROUP BY _time, accountId, accountName, application, applicationVersion, asyncStatusMessageFlag, datacenter, direction, env, host, httpErrorType, httpStatus, internalSuccessful, messageCategory, messageType, messageVersion, os, pool, portalId, portalName, receiverResponse, remoteSuccessful, routableEntityIdQualifier, server_role

For example, replace accountId with "accountId".

[jnativio2]

@hiltontj I tried your suggestion with the CLI and still got the same error. Anyway, how would I force the quoting in the plugin?

[hiltontj]

Are you using Influx's standard downsampler? I will take a look at that to help figure out an answer, but if you're using something else please share.

[hiltontj]

In the standard downsampler, it looks like the the method that generates the GROUP BY clause is not quoting the tag names:

influxdb3_plugins/influxdata/downsampler/downsampler.py

Lines 820 to 833 in 79edd88

	def generate_group_by_string(tags_list: list):
	"""
	Generates the GROUP BY clause for downsampling queries.
	Args:
	tags_list (list): List of tag names to include in the GROUP BY clause.
	Returns:
	str: SQL GROUP BY clause string including '_time' and tags.
	"""
	group_by_clause: str = f"_time"
	for tag in tags_list:
	group_by_clause += f", {tag}"
	return group_by_clause

I reckon the python there should be changed to escape-quote the tag names.

[jnativio2]

Yes, I am using the downsampler standard plugin.

[hiltontj]

I have a potential fix in #30 but I'll need to test it out when I get time.

[Aliaksei-Kharlap]

Hi, @hiltontj You are right, it solves the problem, I tested your solution, it works correctly. I found the same problem in threshold_deadman_checks and fixed it. But I did not make changes to the downsampler plugin, should I make them myself or will you approve your PR?

[hiltontj]

Hey @Aliaksei-Kharlap I am not at my desk this week, I can get it merged next week when I'm back but if you would like to open a separate PR that is okay - it also sounds like this may be an issue with multiple plugins so it may be good to take a pass on the other plugins InfluxData maintains to see if this is an issue in any others.

[Aliaksei-Kharlap]

@hiltontj I fixed dowsampler plugin and uploaded changes, you can close PR draft. I also checked other plugins for similar problem.

[hiltontj]

Hey @Aliaksei-Kharlap - nice! I am back online now, did you submit a PR to close the issue? I don't see one.

[Aliaksei-Kharlap]

@hiltontj
Hi, I did it via commit, because I develop in another repository (https://github.com/influxdata/influxdb3_plugins_dev), and from there I transfer the final changes to this repository. At that time, I had already added changes for other plugins, so I didn’t see the point in opening a new PR. As usual I made a commit and push, I apologize for that. I will start doing PR for all changes.

[hiltontj]

Oh okay, no problem, I see the changes in https://github.com/influxdata/influxdb3_plugins_dev/commit/d3e985c80d5884d421be69c9c0fbfa9220a78b02 and https://github.com/influxdata/influxdb3_plugins_dev/commit/202cc34826a62d21f44f5b74820d0e7f299ca2d7. No worries - once those get merged in here, we can close this issue. I will close my PR, thanks!