featurebase/idk/datagen
2022-11-07 10:51:55 -06:00
..
gen FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
testdata FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
all-field-types.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
bank.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
claim.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
cmd.go Batch insert via SQL (multiple tuples) (#2243) 2022-10-29 14:24:33 -05:00
common.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
custom.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
custom_test.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
customer.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
customer_segmentation.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
customer_segmentation_add_linkedin.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
customer_segmentation_test.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
datagen_test.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
dell.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
dell.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
dwarranty.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
equipment.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
equipment.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
example.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
hobbies.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
hughes.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
item.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
kitchen-sink-keyed.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
kitchen-sink.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
locations.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
merck.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
network.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
palo_alto.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
power_scenario.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
power_scenario_1.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
power_scenario_1_2.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
README.md FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
shared.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
sites.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
sites.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
sizing.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
skills.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
stringpk.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
texas_health.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
timeseries.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
titles.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
transactions.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
transactions_scenario_1.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
uscities.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
warranty.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
zip_codes.data.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00

Datagen Tool

Help Usage

Usage of datagen:
  -c, --concurrency int             Number of concurrent sources and indexing routines to launch. (default 1)
      --dry-run                     Dry run - just flag parsing.
  -e, --end-at uint                 ID at which to stop generating records.
      --kafka.batch-size int        Number of records to generate before sending them to Kafka all at once. Generally, larger means better throughput and more memory usage. (default 1000)
      --kafka.hosts strings         Comma separated list of host:port pairs for Kafka. (default [])
      --kafka.registry-url string   Location of Confluent Schema Registry. Must start with 'https://' if you want to use TLS.
      --kafka.subject string        Kafka schema subject.
      --kafka.topic string          Kafka topic to post to.
      --pilosa.batch-size int       Number of records to read before indexing all of them at once. Generally, larger means better throughput and more memory usage. 1,048,576 might be a good number.
      --pilosa.cache-length uint    Number of batches of ID mappings to cache. (default 64)
      --pilosa.hosts strings        Comma separated list of host:port pairs for Pilosa. (default [])
      --pilosa.index string         Name of Pilosa index.
      --seed int                    Seed to use for any random number generation.
  -s, --source string               Source generator type. Running datagen with no arguments will list the available source types.
  -b, --start-from uint             ID at which to start generating records.
  -t, --target string               Destination for the generated data: [kafka, pilosa]. (default "pilosa")
      --track-progress              Periodically print status updates on how many records have been sourced.

Example Usage

The following command will create 100 records in Pilosa index (starting at ID 0 and ending at ID 99) in the equipment index using the equipment data generator.

datagen --source=equipment --pilosa.index=equipment --end-at=99

Adding New Sources

TODO: redo README (or delete?)

If you're looking to add a new Source to datagen, the best thing to do is use the special "custom" datagen source (datagen --source=custom --custom-config=somefile.yaml) and write a somefile.yaml which describes the data you want to generate. An example can be found in datagen/testdata/custom.yaml, and there are some more in the molecula/technical-validation repo.