Sources de données prises en charge
Formats de données pris en charge
Types de données pris en charge
Types standard
- Types numériques de base - [U]Int8/16/32/64, Float32/64 et BFloat16
- Types entiers de grande taille - [U]Int128/256
- Types Decimal
- Boolean
- String
- FixedString
- Date, Date32
- DateTime, DateTime64 (fuseaux horaires UTC uniquement)
- Enum8/Enum16
- UUID
- IPv4
- IPv6
- Time, Time64
- JSON
- tous les types LowCardinality de ClickHouse
- Map avec des clés et des valeurs utilisant l’un des types ci-dessus (y compris Nullable)
- Tuple et Array avec des éléments utilisant l’un des types ci-dessus (y compris Nullable, profondeur d’un seul niveau uniquement)
- Types SimpleAggregateFunction (pour les destinations AggregatingMergeTree ou SummingMergeTree)
Prise en charge du type Variant
- Unions Avro. Si votre schéma Avro contient une union avec plusieurs types non NULL, ClickPipes inférera le type Variant approprié. Les types Variant ne sont pas pris en charge autrement pour les données Avro.
- Champs JSON. Vous pouvez spécifier manuellement un type Variant (tel que
Variant(String, Int64, DateTime)) pour n’importe quel champ JSON dans le flux de données source. Les sous-types complexes (arrays/maps/tuples) ne sont pas pris en charge. De plus, en raison de la façon dont ClickPipes détermine le sous-type Variant approprié à utiliser, un seul type entier ou DateTime peut être utilisé dans la définition de Variant - par exemple,Variant(Int64, UInt32)n’est pas pris en charge.
Prise en charge du type JSON
- Les champs record Avro et message Protobuf peuvent toujours être affectés à une colonne JSON.
- Les champs Avro String et Bytes peuvent être affectés à une colonne JSON si le champ Avro contient réellement des objets JSON String.
- Les types Protobuf String et Bytes peuvent être affectés à une colonne JSON si le champ Protobuf contient réellement des objets JSON String.
- Les champs JSON qui sont toujours des objets JSON peuvent être affectés à une colonne JSON de destination.
Avro
Types de données Avro pris en charge
local-timestamp-millis et local_timestamp-micros. Les types Avro record sont convertis en Tuple, les types array en Array, et map en Map (clés de type chaîne uniquement). De manière générale, les conversions répertoriées ici sont disponibles. Nous recommandons d’utiliser une correspondance exacte des types pour les types numériques Avro, car ClickPipes ne vérifie pas les dépassements de capacité ni les pertes de précision lors des conversions de type.
Sinon, tous les types Avro peuvent être insérés dans une colonne String et seront alors représentés sous la forme d’une chaîne JSON valide.
Types Nullable et unions Avro
(T, null) ou (null, T), où T est le type Avro de base. Lors de l’inférence de schéma, ces unions sont mappées sur une colonne ClickHouse « Nullable ». Notez que ClickHouse ne prend pas en charge les types
Nullable(Array), Nullable(Map) ou Nullable(Tuple). Les unions Avro avec null pour ces types seront mappées sur des versions non Nullable (les types record Avro sont mappés sur un named Tuple ClickHouse). Les valeurs « null » Avro pour ces types seront insérées comme suit :
- Un Array vide pour un tableau Avro null
- Une Map vide pour une Map Avro null
- Un named Tuple avec toutes les valeurs par défaut/à zéro pour un record Avro null
Protobuf
Types de données Protobuf pris en charge
group de proto 2, obsolète de longue date. Les conversions de types de base utilisent
les correspondances suivantes :
Les variantes
Array, Map et Nullable de tous les types de base sont également prises en charge.
Les types bien connus suivants sont également pris en charge :
Protobuf oneof
oneof sont, par défaut, mappés sur un Tuple nommé, dans lequel un seul champ au maximum contient une
valeur autre que la valeur par défaut. Ces champs peuvent également être automatiquement mappés sur une colonne Variant, où la valeur active prend le type du
champ constitutif qui est défini. Autrement, chaque champ constitutif peut être mappé manuellement à sa propre colonne ClickHouse ; comme les champs oneof
sont mutuellement exclusifs, une seule colonne sera renseignée pour chaque enregistrement.
Listes de messages
Colonnes virtuelles Kafka
Add Column.
Notez que la colonne
_raw_message n’est recommandée que pour les données JSON.
Pour les cas d’usage où seule la chaîne JSON est requise (par exemple, lors de l’utilisation des fonctions ClickHouse JsonExtract* pour
alimenter une vue matérialisée en aval), la suppression de toutes les colonnes « non virtuelles » peut améliorer les performances de ClickPipes.